1 了解线程池
1-1线程池的概述
由一个任务队列和一组处理队列的线程组成。一旦工作进程需要处理某个可能“阻塞”的操作，不用自己操作，将其作为一个任务放到线程池的队列，接着会被某个空闲线程提取处理。
1-2线程池的组件
任务 待处理的工作，通常由标识、上下文和处理函数组成。
任务队列 按顺序保存待处理的任务序列，等待线程中的线程组处理。
线程池 由多个已启动的一组线程组成。
条件变量 一种同步机制，允许线程挂起，直到共享数据上的某些条件得到满足。
互斥锁 保证在任一时刻，只能有一个线程访问该对象。
2 互斥锁 与 条件变量 自定义封装 声明 与 定义
thread.h
#ifndef _DEMO_THREAD_H_INCLUDED_
#define _DEMO_THREAD_H_INCLUDED_#include <stdio.h>
#include <stdint.h>
#include <stdlib.h>
#include <sys/types.h>
#include <pthread.h>
#include <errno.h>
#include <string.h>typedef intptr_t int_t;
typedef uintptr_t uint_t;#define OK 0
#define ERROR -1//---------互斥量(互斥锁)接口的封装-----------定义:thread_mutex.c
int thread_mutex_create(pthread_mutex_t *mtx); //线程 互斥锁的 创建
int thread_mutex_destroy(pthread_mutex_t *mtx); //线程 互斥锁的 销毁
int thread_mutex_lock(pthread_mutex_t *mtx); //线程 互斥锁的 加锁
int thread_mutex_unlock(pthread_mutex_t *mtx); //线程 互斥锁的 解锁//---------条件变量接口的封装-----------------定义:thread_cond.c
int thread_cond_create(pthread_cond_t *cond); //线程 条件变量的 创建
int thread_cond_destroy(pthread_cond_t *cond); //线程 条件变量的 销毁
int thread_cond_signal(pthread_cond_t *cond); //线程 条件变量的 信号发送
int thread_cond_wait(pthread_cond_t *cond, //线程 条件变量的 信号接受pthread_mutex_t *mtx); #endif /* _DEMO_THREAD_H_INCLUDED_ */thread_mutex.c
#include "thread.h"//互斥锁的创建
int thread_mutex_create(pthread_mutex_t *mtx)
{int err;pthread_mutexattr_t attr; //互斥锁属性变量//1对互斥变量属性 pthread_mutexattr_t 初始化err = pthread_mutexattr_init(&attr);if (err != 0) {fprintf(stderr, "pthread_mutexattr_init() failed, reason: %s\n",strerror(errno));return ERROR;}//2设置互斥变量防 死锁检测 PTHREAD_MUTEX_ERRORCHECK 不允许同一个线程多次获取同一个锁导致的死锁err = pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_ERRORCHECK);if (err != 0) {fprintf(stderr, "pthread_mutexattr_settype(PTHREAD_MUTEX_ERRORCHECK) failed, reason: %s\n",strerror(errno));return ERROR;}//3对创建的互斥锁 mtx 设置 attr 属性err = pthread_mutex_init(mtx, &attr);if (err != 0) {fprintf(stderr,"pthread_mutex_init() failed, reason: %s\n",strerror(errno));return ERROR;}//3销毁互斥锁属性变量err = pthread_mutexattr_destroy(&attr);if (err != 0) {fprintf(stderr,"pthread_mutexattr_destroy() failed, reason: %s\n",strerror(errno));}return OK;
}//互斥锁的销毁
int thread_mutex_destroy(pthread_mutex_t *mtx)
{int err;err = pthread_mutex_destroy(mtx);if (err != 0) {fprintf(stderr,"pthread_mutex_destroy() failed, reason: %s\n",strerror(errno));return ERROR;}return OK;
}//互斥锁上锁
int thread_mutex_lock(pthread_mutex_t *mtx)
{int err;err = pthread_mutex_lock(mtx);if (err == 0) {return OK;}fprintf(stderr,"pthread_mutex_lock() failed, reason: %s\n",strerror(errno));return ERROR;
}//互斥锁解锁
int thread_mutex_unlock(pthread_mutex_t *mtx)
{int err;err = pthread_mutex_unlock(mtx);#if 0ngx_time_update();
#endifif (err == 0) {return OK;}fprintf(stderr,"pthread_mutex_unlock() failed, reason: %s\n",strerror(errno));return ERROR;
}thread_cond.c
#include "thread.h"int thread_cond_create(pthread_cond_t *cond)
{int
