ToB企服应用市场:ToB评测及商务社交产业平台

标题: 任务队列C++实现-（完美转发） [打印本页]
作者: 飞不高    时间: 2023-11-27 09:05
标题: 任务队列C++实现-（完美转发）
需求

代码实现
  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. }
复制代码
实现笔记

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

判断表达式左值还是右值的两种办法：
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



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4