#include 
  
   
#include 
   
     #include 
    
      #include 
     
       #include 
      
        #include 
       
         #include 
        
          #include 
         
           using namespace std; /********************************同步队列******************************/ template 
          
            class SyncQueue { public: SyncQueue(int maxSize): m_maxSize(maxSize), m_needStop(false) { } //添加事件 void Put(const T& x) { Add(x); } //添加事件 void Put(T && x) { //调用内部接口,进行完美转发 Add(std::forward
           
            (x)); } //从队列中取事件,取所有事件 void Take(std::list
            
              &list) { std::unique_lock
             
               locker(m_mutex); //当不满足任何一个则等待,但是若m_needStop为true是因为任务要终止了所以不阻塞 m_notEmpty.wait(locker, [this]{return (m_needStop || NotEmpty()); }); if (m_needStop) { return; } list = std::move(m_queue); m_notFull.notify_one(); } //取一个事件 void Take(T &t) { std::unique_lock
              
                locker(m_mutex); m_notEmpty.wait(locker, [this]{return m_needStop || NotEmpty(); }); if (m_needStop) { return; } t = m_queue.front(); m_queue.pop_front(); m_notFull.notify_one(); } //终止同步队列 void Stop() { { //锁作用域就在这对大括号内 std::lock_guard
               
                 locker(m_mutex); //将终止标志设为true m_needStop = true; } //唤醒所有进程一一终止 m_notFull.notify_all(); m_notEmpty.notify_all(); } //队列为空 bool Empty() { std::lock_guard
                
                  locker(m_mutex); return m_queue.empty(); } //队列为满 bool Full() { std::lock_guard
                 
                   locker(m_mutex); return m_queue.size() == m_maxSize; } //队列大小 size_t Size() { std::lock_guard
                  
                    locker(m_mutex); return m_queue.size(); } //队列大小 int Count() { return m_queue.size(); } private: //队列不为满 bool NotFull() const { bool full = (m_queue.size() >= m_maxSize); if (full) { cout << "the queue is full, need wait..." << endl; } return !full; } //队列不为空 bool NotEmpty() const { bool empty = m_queue.empty(); if (empty) { cout << "the queue is empty, need wait..., 异步层的线程ID: " << this_thread::get_id() << endl; } return !empty; } //向队列中添加事件,若不为满且终止标志为false则添加事件 template 
                   
                     void Add(F && x) { std::unique_lock
                    
                      locker(m_mutex); //当不满足任何一个则等待,但是若m_needStop为true是因为任务要终止了所以不阻塞 m_notFull.wait(locker, [this]{return m_needStop || NotFull(); }); if (m_needStop) { return; } m_queue.push_back(std::forward
                     
                      (x)); m_notEmpty.notify_one(); } private: //缓冲区 std::list
                      
                        m_queue; //互斥量 std::mutex m_mutex; //队列不为空的条件变量 std::condition_variable m_notEmpty; //队列不为满的条件变量 std::condition_variable m_notFull; //任务队列最大长度 int m_maxSize; //终止的标识,当为true时代表同步队列要终止 bool m_needStop; }; /**************************线程池********************************/ //传递给同步队列的最大个数 const int MaxTaskCount = 100; class ThreadPool { public: using Task = std::function
                       
                        ; //构造函数,默认参数hardware_concurrency()获取CPU核心数量 ThreadPool(int numThreads = std::thread::hardware_concurrency()):m_queue(MaxTaskCount) { cout << "numThreads: " <<　numThreads　<< endl; Start(numThreads); } ~ThreadPool() { Stop(); } //保证多线程环境下只调用一次StopThreadGroup函数 void Stop() { std::call_once(m_flag, [this]{ StopThreadGroup(); }); } //添加任务,右值完美转发 void AddTask(Task && task) { m_queue.Put(std::forward
                        
                          (task)); } //添加任务 void AddTask(const Task && task) { m_queue.Put(task); } private: //建立numThreads个数的线程组 void Start(int numThreads) { m_running = true; for (int i = 0; i < numThreads; i++) { //多个线程依次的处理 m_threadgroup.push_back(std::make_shared
                         
                          (&ThreadPool::RunInThread, this)); } } //取出任务队列中的全部,依次执行 void RunInThread() { while (m_running) { std::list
                          
                            list; m_queue.Take(list); for (auto & task : list) { if (!m_running) { return ; } //执行任务 task(); } } } //终止所有任务的执行 void StopThreadGroup() { //终止同步队列 m_queue.Stop(); m_running = false; for (auto thread : m_threadgroup) { if (thread) { thread->join(); } } m_threadgroup.clear(); } private: //处理任务的线程组 std::list
                           
                            > m_threadgroup; //同步队列 SyncQueue
                            
                              m_queue; //运行的标志,flase代表终止 atomic_bool m_running; //