A Thread Pool Realized by Pthread
博客：https://blog.csdn.net/Gryphoon/article/details/98397581
使用pthread实现的简单线程池，可以通过源码学习线程池的基本原理
将文件 PthreadPool.h 和 PthreadPool.cpp 拷贝到需要使用的源码目录下，将头文件include在源码中，在编译时加上参数 -lpthread 即可
- 使用C++开发
- 在创建时指定线程池中的线程数量
class PthreadPool
{
private:
pthread_mutex_t lock; // 互斥锁
pthread_cond_t notify; // 条件变量
queue<Pthreadpool_Runable> thread_queue; // 任务队列
pthread_t *threads; // 任务数组
int shutdown; // 表示线程池是否关闭
static void *threadpool_thread(void *threadpool); // 运行函数
public:
PthreadPool();
~PthreadPool();
int thread_num; // 线程数量
int running_num; // 正在运行的线程数
int waiting_num; // 队列中等待的数目
int Init(unsigned int num); // 初始化线程池
int AddTask(void (*function)(void *), void *argument = nullptr); // 加入任务
int Destory(PthreadPool_Shutdown flag = graceful_shutdown); // 停止正在进行的任务并摧毁线程池
};int Init(unsigned int num); // 初始化线程池
int AddTask(void (*function)(void *), void *argument = nullptr); // 加入任务
int Destory(PthreadPool_Shutdown flag = graceful_shutdown); // 停止正在进行的任务并摧毁线程池在使用前先创建对象 PthreadPool pool;
然后再初始化线程池 pool.Init(4);
在线程池中加入任务 pool.AddTask(&dummy_task)
在程序结束时销毁线程池 pool.Destory();
销毁线程池可以提供参数
enum PthreadPool_Shutdown {
graceful_shutdown = 1, // 等待线程结束后关闭
immediate_shutdown = 2 // 立即关闭
};提供了一个简单的测试程序
g++ PthreadPool.cpp Test.cpp -lpthread -std=c++11 -o pthreadpool