为什么会有线程池？

大多数的服务器可能都有这样一种情况，就是会在单位时间内接收到大量客户端请求，我们可以采取接受到客户端请求创建一个线程的方式来执行，虽然线程对于进程来说开销已经很低了，但是大量的请求，也会占用巨量cpu资源。那么我们能不能采取一种方法来解决这个问题呢。线程池就出现了，假设我们会创建5个空闲线程，我们会将这些任务存入到队列中，当我们有空闲线程时就来处理任务，这样占用巨大cpu资源的情况是不是就能解决了呢。

实现简单的线程池

#pragma once#include <stdio.h>
#include <stdlib.h>
/*
任务类：线程所要实现的功能在任务类中实现
*/
class Ctask
{
public:Ctask();~Ctask();void run();
private:};

#include "Ctask.h"Ctask::Ctask()
{}Ctask::~Ctask()
{
}void Ctask::run()
{printf("do task !\n");}

线程池需要一个锁，为什么呢？其实很简单，多个线程同时调用的，会出现竞争的情况，那么使用锁，可以防止这种情况。
同时还有一个问题，当任务来的时候，我们怎么让线程知道，这时我们所采用的就是条件变量，当任务来的时候，通知线程来执行

#include <stdio.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <strings.h>
#include <string.h>
#include <ctype.h>
#include <signal.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <time.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <iostream>
#include <stack>
#include <queue>
#include "Ctask.h"
using namespace std;typedef struct thread_pool
{pthread_cond_t cond;pthread_mutex_t mutex;int idel;  //当前空闲线程的数量,如果空闲线程>0,唤醒线程,如果没有，创建新线程int count;//当前有多少线程queue<Ctask*>task;
}THREAD_POOL_T;
class Threadpool
{
public:THREAD_POOL_T pool;//线程池初始化Threadpool();~Threadpool();void thread_pool_add_task(Ctask* t);
private:};

#include "Threadpool.h"void* start_routine(void* arg)
{THREAD_POOL_T* pool = (THREAD_POOL_T*)arg; //转化while (1){//加锁pthread_mutex_lock(&pool->mutex);pool->idel++;if (pool->task.empty())//如果任务队列为空，条件变量等待加入任务{cout << "wait for wake .... =>" << pthread_self() << endl;pthread_cond_wait(&pool->cond,&pool->mutex);cout << "wake up .... =>" << pthread_self() << endl;}//取走任务pool->idel--;//从线程池里取走任务Ctask* t = pool->task.front();pool->task.pop();//解锁pthread_mutex_unlock(&pool->mutex);printf("%d\n",pool->task.size());t->run();}}Threadpool::Threadpool()
{//初始化条件变量pthread_cond_init(&pool.cond,NULL);//初始化锁pthread_mutex_init(&pool.mutex,NULL);pool.idel = 0;pool.count = 0;//默认创建三个线程for (int i = 0; i < 3; i++){pthread_t pid;pthread_create(&pid,NULL,start_routine,&pool);pool.count++;}}Threadpool::~Threadpool()
{}void Threadpool::thread_pool_add_task(Ctask* t)
{//printf("3\n");//往pool这个线程池结构体的队列里面添加一个任务pthread_mutex_lock(&pool.mutex);pool.task.push(t);//把任务加到线程池的栈里面，相当于存起来//判断有没有空闲线程，如果有，就唤醒线程if (pool.idel > 0){pthread_cond_signal(&pool.cond);}else{pthread_t tid;pthread_create(&tid, NULL, start_routine, &pool);}pthread_mutex_unlock(&pool.mutex);}

#include <cstdio>
#include "Threadpool.h"int main()
{//创建一个线程池，5个线程//往线程池里面添加任务，线程会执行任务Threadpool* pool = new Threadpool();for (int i = 0; i < 10; i++){Ctask* t=new Ctask();pool->thread_pool_add_task(t);}while (1){}}