C语言实现一个简单的线程池 - c语言编程

d_cond_signal(&(pool->queue_cond)); pthread_mutex_unlock(&(pool->queue_mutex)); return 0; } int thread_pool_destroy() { if(pool->is_pool_destroyed)//防止多次销毁 return -1; pool->is_pool_destroyed = 1; pthread_cond_broadcast(&(pool->queue_cond));//通知所有线程线程池销毁了 int i; for(i=0; ithread_num; i++)//等待线程全部执行完 pthread_join(pool->thread_queue[i], NULL); //销毁任务队列 task *temp = NULL; while(pool->task_queue_head) { temp = pool->task_queue_head; pool->task_queue_head = pool->task_queue_head->next; free(temp); } //pool->task_queue_head = NULL； //pool->task_queue_end = NULL； //销毁线程队列 free(pool->thread_queue); pool->thread_queue = NULL; pthread_mutex_destroy(&(pool->queue_mutex)); pthread_cond_destroy(&(pool->queue_cond)); free(pool); pool = NULL; return 0; }
test.c

#include "thread_pool.h"
#include 

void *taskprocess(void *arg)
{
	printf("aaaaaadoing tasksaaaaaaaaa\n");
	usleep(1000);
	return NULL;
}


int main()
{
	thread_pool_init(5);
	int i;
	for(i=1; i<=10; i++)
	{
		thread_pool_add_task(taskprocess,(void *)i);
		usleep(1000);
	}
	sleep(1);
	thread_pool_destroy();
	return 0;
}

C语言实现一个简单的线程池(二)