CxxThreadPool

Simple, header-only Thread Pool Class for C++11 ( or newer ). Inspired by the Qt ThreadPool Class. A progress bar will be printed out to cerr.

Usage

Include the CxxThreadPool.h in your project and link your project against pthread ( at least on *nx systems ).

Subclass CxxThread and reimplement

virtual int execute() = 0;

like for example

inline int execute()
{
    printf("Thread  started  ...\n");
    std::this_thread::sleep_for(std::chrono::milliseconds(1500));
    printf("Thread finished! .. \n",);
    return 0;
}

Use

CxxThreadPool *pool = new CxxThreadPool;
pool->setActiveThreadCount(32);

to control the number of active threads and add a single CxxThread derived object with

pool->addThread(thread);

. After adding a thread to the pool, CxxThreadPool takes ownership of the object and deletes it upon deleting the CxxThreadPool object. To prevent automatic deletion, set autodelete to false:

thread->setAutoDelete(false);

Please take care of the object then.

Finally, run all queued threads parallel with

pool->StartAndWait();

Access to all finished threads can be obtained using the Finished() function:

for(const auto *t : pool->Finished())
{
    const OwnThreadClass *thread = static_cast<const OwnThreadClass *>(t);
    /*
    do your fancy stuff
    */
}

Increase verbosity by defining

#define _CxxThreadPool_Verbose

Prevent of a progress bar appearing

#define _CxxThreadPool_NoBar

Define width of the progress bar

#define _CxxThreadPool_BarWidth

Wakeup timeout for to check threads in milliseconds ( default = 100 )

#define _CxxThreadPool_TimeOut 100

before including the header file.

Have a lot of fun.