CPP服务器06--线程池实现(2)

上篇文章中的线程池，功能相对完整，有管理调度线程．但接口定义通用性差，需要修改，奈何目前水平不够，只能先找一个能用的替换，以后再改吧．

• // std::thread :https://subingwen.cn/cpp/thread/

• // std::function :https://blog.csdn.net/jinzhu1911/article/details/101307637

• // template　: https://www.cnblogs.com/qicosmos/p/4325949.html

• // std::future 　:　https://www.zhihu.com/question/447107869

• // std::move std::forward : https://www.jianshu.com/p/b90d1091a4ff

• // std::mutex

• // std::condition_variable

• // std::unique_lock

• // std::make_shared

#ifndef THREADPOOL_H
#define THREADPOOL_H

#include
#include
#include
#include
#include
#include

class ThreadPool{
private:
    bool m_stop;
    std::vectorm_thread;        //工作线程队列
    std::queue>tasks;  //任务队列
    std::mutex m_mutex;                      //互斥锁
    std::condition_variable m_cv;            //条件变量

public:
    explicit ThreadPool(size_t threadNumber):m_stop(false){
        for(size_t i=0;itask;
                        {
                            std::unique_locklk(m_mutex);
                            m_cv.wait(lk,[this](){ return m_stop||!tasks.empty();});
                            if(m_stop&&tasks.empty()) return;
                            task=std::move(tasks.front());
                            tasks.pop();
                        }
                        task();
                    }
                }
            );
        }
    }

    ThreadPool(const ThreadPool &) = delete;　//禁止拷贝构造
    ThreadPool(ThreadPool &&) = delete;

    ThreadPool & operator=(const ThreadPool &) = delete; //禁止赋值
    ThreadPool & operator=(ThreadPool &&) = delete;

    ~ThreadPool(){
        {
            std::unique_locklk(m_mutex);
            m_stop=true;
        }
        m_cv.notify_all();
        for(auto& threads:m_thread)
        {
            threads.join();
        }
    }

    template
    auto submit(F&& f,Args&&... args)->std::future{
        auto taskPtr=std::make_shared>(
            std::bind(std::forward(f),std::forward(args)...)
        );
        {
            std::unique_locklk(m_mutex);
            if(m_stop) throw std::runtime_error("submit on stopped ThreadPool");
            tasks.emplace([taskPtr](){ (*taskPtr)(); });
        }
        m_cv.notify_one();
        return taskPtr->get_future();

    }
};

#endif //THREADPOOL_H
                     

• 基于C++11实现线程池 - Skykey的文章 - 知乎
  https://zhuanlan.zhihu.com/p/367309864
• https://github.com/Aged-cat/WebServer