模拟muduo使用bind与function模板创建线程池

上一篇博客中，我们讲解了function模版与std::bind，如下

c++可调用对象、function类模板与std::bind-CSDN博客https://blog.csdn.net/qq_58158950/article/details/135590153?spm=1001.2014.3001.5501

今天我们使用这两个模版来模仿muduo网络库实现一个微型线程池?

#include<iostream>
#include<functional>
#include<vector>
#include<thread>
using namespace std;
using namespace placeholders;

class Thread
{
public:
    Thread(function<void()> func):_func(func){}
    //创建线程函数
    thread start()
    {
        return thread(_func);
    }
private:
    function<void()> _func;//已经被绑定过的线程执行函数
};

class ThreadPool
{
public:
    ThreadPool(){}

    virtual ~ThreadPool(){
        for(int i=0;i<_pool.size();i++)
            delete _pool[i];
    }

    //开启线程池
    void startPool(int size)
    {
        //将线程执行函数添加到线程对象中
        for(int i=0;i<size;i++)
        {
            _pool.push_back(
                //使用bind器直接将执行函数绑定到thread对象里
                new Thread(bind(&ThreadPool::runInThread,this,i))
                );
        }

        //创建线程池中的线程
        for(int i=0;i<size;i++)
        {
            _header.push_back(_pool[i]->start());
        }

        //等待所有子线程结束
        for(thread &t:_header)
        {
            t.join();
        }
    }
private:
    vector<Thread*> _pool;//线程池
    vector<thread> _header;//用于保存已经创建成功的线程对象

    //充当一个线程执行函数
    void runInThread(int id)
    {
        cout<<"call runInTHread id is "<<id<<endl;
    }
};

void test()
{
    ThreadPool pool;//定义线程池对象
    pool.startPool(10);//在线程池中创建10个线程
}
int main()
{
    test();
    return 0;
}