linux网络编程之简单的线程池实现

转眼间离15年的春节越来越近了，还有两周的工作时间貌似心已经不在异乡了，期待与家人团聚的日子，当然最后两周也得坚持站好最后一班岗，另外期待的日子往往是心里不能平静的，越是想着过年，反而日子过得越慢，于是乎，还是用学习来充斥这些碎片时间，当人一充实，时间也就过得快了，继续学习：

上次中已经用互斥锁与条件变量来改造了生产者与消费者问题，这次利用它来实现一个线程池，加强对条件变量及互斥锁的认识，下面开始：

关于什么是线程池，这里就不多说了，应该基本都在实际中用到过，下面关于线程池实现有几个点需要说明一下：

线程池，顾名思义就是拥有若干个线程，对于线程的个数是有严格的要求的，并非越多越好，太多了会增加系统的开销，太少了又会降低并发量。

执行时间较长的任务是不太适合放在线程池中进行处理，比如说：线程的执行时间跟进程的生命周期是一致的，那么这个任务的执行就没必要放到线程池中进行，直接用普通的线程既可。

那线程池当中的线程个数究竟存放多少个比较合适呢？实际上这跟任务类型有关系：

①、计算密集型任务：一般这个任务是占用CPU的，它很少被外界的事件打断，这时线程个数 = CPU个数，如果线程个数>CPU个数，由于CPU的个数是一定的，那么能够并发的数目也是一定的，所以会用少量的CPU个数来调度多个线程，这肯定会涉及到线程与线程之间的切换开销，因而会降低效率。

②、I/O密集型任务：这种任务在运行时，可能会被I/O中断，也就是说这个线程会挂起，这时线程个数 > CPU个数，

那接下来先了解一下线程池实现中，需要用到的结构体：

下面则开始实现，首先在头文件中定义上面的数据结构:

其中用到了条件变量，这里对条件变量进行了简单的封装，所以先来看下是如何封装的：

从声明的这些函数中很容易就能想到它们的各个实现：

condition.c:

#include "condition.h"

//初使化条件变量，可想而知是对互斥锁和条件变量进行初始化
int condition_init(condition_t *cond)
{
    int status;
    if ((status = pthread_mutex_init(&cond->pmutex, NULL)))
        return status;

    if ((status = pthread_cond_init(&cond->pcond, NULL)))
        return status;

    return 0;
}

//对互斥锁进行锁定
int condition_lock(condition_t *cond)
{
    return pthread_mutex_lock(&cond->pmutex);
}

//对互斥锁进行解锁
int condition_unlock(condition_t *cond)
{
    return pthread_mutex_unlock(&cond->pmutex);
}

//在条件变量上等待条件
int condition_wait(condition_t *cond)
{
    return pthread_cond_wait(&cond->pcond, &cond->pmutex);
}

//具有超时功能的等待功能
int condition_timedwait(condition_t *cond, const struct timespec *abstime)
{
    return pthread_cond_timedwait(&cond->pcond, &cond->pmutex, abstime);
}

//向等待线程发起一个通知
int condition_signal(condition_t *cond)
{
    return pthread_cond_signal(&cond->pcond);
}

//向等待线程发起广播
int condition_broadcast(condition_t* cond)
{
    return pthread_cond_broadcast(&cond->pcond);
}

//销毁条件变量
int condition_destroy(condition_t* cond)
{
    int status;
    if ((status = pthread_mutex_destroy(&cond->pmutex)))
        return status;

    if ((status = pthread_cond_destroy(&cond->pcond)))
        return status;

    return 0;
}