A simple implementation of thread pooling for C/C++ using POSIX threads
A simple implementation of thread pooling for C/C++ using POSIX threads.
Each pool has a designated worker function, and expects to be given a number of
work items. Any thread in the pool can take a work item, and will pass the work
item to the pool's worker function. The work items are void *
, and are passed
to the worker function exactly as they are given to pool_enqueue
. The return
values of the worker functions are ignored.
Four functions of interest are provided:
pool_start
will start a new pool. The worker function and number of
threads in the pool need to be given as arguments.pool_enqueue
will add a new work item to the pool. The work item data
pointer should be passed, as well as a flag specifying whether the work item
should be free'd after the work item has been processed (or if the pool is
terminated).pool_wait
will block until all queued work items have been processed.pool_end
should be called when the pool is no longer needed. This
terminates the threads, deallocates the queue and the pool, as well as any
freeable work items.Further documentation is given in Doxygen format in pthread_pool.h
.