任务队列C++实现-（完美转发）

需求

• 任务队列中可以依次添加任务；
  
• 任务执行函数需要接受外部传输的参数；
  
• 主动调用Start开始执行任务；
  

代码实现

1. class TaskQueue {
2. private:
3.     std::mutex mtx;
4.     std::condition_variable cv;
5.     std::queue<std::function<void()>> task_queue;
6.     std::atomic<bool> is_running;
8. public:
9.     TaskQueue() : is_running(false) {}
10.     ~TaskQueue() {}
12.     // std::forward is used to forward the parameter to the function
13.     template<typename F, typename... Args>
14.     void Push(F&& f, Args&&... args) {
15.         std::lock_guard<std::mutex> lock(mtx);
16.         task_queue.push(std::bind(std::forward<F>(f), std::forward<Args>(args)...));
17.         cv.notify_one();
18.     }
20.     void Start() {
21.         is_running = true;
22.         std::thread t([this] {
23.             while(is_running) {
24.                 std::unique_lock<std::mutex> lock(mtx);
25.                 cv.wait(lock, [this] { return !task_queue.empty(); });
26.                 auto task = task_queue.front();
27.                 task_queue.pop();
28.                 lock.unlock();
29.                 task();
30.             }
31.         });
32.         t.detach();
33.     }
35.     void Stop() {
36.         is_running = false;
37.     }
38. };

复制代码

1. int main(int argc, char** argv) {
3.     TaskQueue tq;
4.     tq.Push(DoSomething, 1);
5.     tq.Push(DoSomething, 2);
6.     tq.Push(DoSomething, 3);
7.     tq.Start();
8.     tq.Push(DoSomething, 4);
10.     // 等待任务结束
11.     while(1) {
12.         std::this_thread::sleep_for(std::chrono::seconds(1));
13.     }
15.     return 0;
16. }

复制代码

实现笔记

任务队列，将需要执行的任务存储在队列中，存储的这个动作类似于生产者；
当任务队列不为空时，会从队列中取出一个任务执行，当任务执行结束后再从队列取下一个，直到队列为空；
执行任务类似于消费者；
基础概念理解

• C++左值和右值
  

判断表达式左值还是右值的两种办法：
a. 位于赋值符号=左侧的就是左值，只能位于右侧的就是右值；需要注意的是，左值也可以当右值用；
b. 有名称、可以取到存储地址的表达式就是左值，否则就是右值；
C++右值引用（用 &&标识）

1.   1. 和左值引用一样，右值引用也需要立即被初始化，且只能使用右值进行初始化

复制代码

1. int num = 10;
2. // 左值不能用于初始化右值
3. // int &&a = num; 编译报错
4. int &&a = 123;

复制代码

1.   2. 和常量左值引用不同的是，右值引用可以对右值进行修改：

复制代码

[code]int num = 10;int &&ref = 12;ref = 222;// 修改右值引用的值std::cout