小编Iva*_*nev的帖子

我必须创建一个线程安全的工作队列,它可以在不同的线程中弹出工作,并在工作线程上处理它.这项工作可能非常通用,所以我在考虑使用带捕获的lambdas作为允许这种情况的好方法.我有以下代码作为启动器:

#include <iostream>
#include <vector>
#include <functional> 
typedef std::function<void()> Task;
typedef std::vector<Task> TaskQueue;

class Queue 
{
   public:
    void flush() {
        for (auto it : m_queue) {
            it();
        }
    }
   // will add thread safe locks later.        
    void queue(Task task) {
        m_queue.push_back(task);
    }

private:
    TaskQueue m_queue;
};
Queue q;

class WorkMaker
{
public: 

    WorkMaker(int inA) : m_a(inA) {}

    void MakeWork() {
        q.queue([&]{
            std::cout << this->m_a << std::endl;
        });
    }


private:
    int m_a;
};

int main()
{
  WorkMaker w1(1);
  WorkMaker w2(2);
  w1.MakeWork(); …