threadpool.h

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<pthread.h>
#include<signal.h>
#include<errno.h>
#include<assert.h>

#define DEFAULT_TIME			10		//10s检测一次
#define MIN_WAIT_TASK_NUM		10		/*如果queue_size > MIN_WAIT_TASK_NUM 添加新的线程到线程池*/ 
#define DEFAULT_THREAD_VARY		3		/*每次创建和销毁线程的个数*/
#define true					1
#define false					0
#define MIN_THREAD_NUM			5		//最小线程数
#define MAX_THREAD_NUM			50		//最大线程数
#define	QUEUE_MAX_SIZE			50		//队列最大数

typedef struct {
	void *(*function) (void *);			/* 函数指针，回调函数 */
	void *arg;							/* 上面函数的参数 */
} threadpool_task_t;					/* 各子线程任务结构体 */

/* 描述线程池相关信息 */
typedef struct threadpool_t {
	/*
	*	条件变量用于某个线程需要在某种条件成立时才去保护它将要操作的临界区，
	*	这种情况从而避免了线程不断轮询检查该条件是否成立而降低效率的情况。
	*	在条件满足时，自动退出阻塞，再加锁进行操作。
	*/
	pthread_mutex_t lock;               /* 用于锁住本结构体 ，和条件变量一起使用 */    
	pthread_mutex_t thread_counter;     /* 记录忙状态线程个数的锁 -- busy_thr_num */
	pthread_cond_t queue_not_full;      /* 当任务队列满时，添加任务的线程阻塞，等待此条件变量 */
	pthread_cond_t queue_not_empty;     /* 任务队列里不为空时，通知线程池中等待任务的线程 */
 
	pthread_t *threads;                 /* 存放线程池中每个线程的tid。数组 */
	pthread_t adjust_tid;               /* 存管理线程tid */
	threadpool_task_t *task_queue;      /* 任务队列 */
 
	int min_thr_num;                    /* 线程池最小线程数 */
	int max_thr_num;                    /* 线程池最大线程数 */
	int live_thr_num;                   /* 当前存活线程个数 */
	int busy_thr_num;                   /* 忙状态线程个数 */
	int wait_exit_thr_num;              /* 要销毁的线程个数 */
 
	int queue_front;                    /* task_queue队头下标 */
	int queue_rear;                     /* task_queue队尾下标 */
	int queue_size;                     /* task_queue队中实际任务数 */
	int queue_max_size;                 /* task_queue队列可容纳任务数上限 */
 
	int shutdown;                       /* 标志位，线程池使用状态，true或false */
} threadpool_t;
 
/* 创建线程池 */
threadpool_t *threadpool_create(int min_thr_num, int max_thr_num, int queue_max_size);

/* 向任务队列中， 添加一个任务 */
int threadpool_add(threadpool_t *pool, void *(*function)(void *arg), void *arg);

/* 销毁线程池 */
int threadpool_destroy(threadpool_t *pool);
int threadpool_free(threadpool_t *pool);

/* 线程池中工作线程要做的事情 */
void* threadpool_thread( void *threadpool );

/* 管理者线程要做的事情 */
void *adjust_thread( void *threadpool );