如何实现阻塞处理循环？

Question

我想在工作线程中实现一个处理循环，以便它在有东西时处理队列中的数据并阻塞（线程休眠）否则......这甚至可能吗？也应该没有任何明显的延迟。

像这样简单的事情：

std::deque<Foo> queue;

void worker() 
{
    while (active) {
        blockAndWaitForData();

        while (!queue.empty()) {
            doSomething(queue.front());
            queue.pop_front();
        }
    }
}

当然需要锁定队列以及一些其他细节。

如果需要，也可以直接使用 Linux API。

Answer 1

C++11 标准中有一些东西可以满足您的需求。它是condition_variable。它允许您等到其他线程通知它。所以你的工人可以等到生产者这样通知它。请注意，这是一个非常愚蠢的示例，在大多数情况下还不够，但可以为您提供如何做到这一点的要点

std::deque<int> q;
std::mutex m;
std::condition_variable cv;

void worker() {
    while (active) {
        std::deque<int> vals;
        {
            std::unique_lock<std::mutex> l(m);
            cv.wait(l, []{return q.empty();});
            vals = std::move(q);
            q.clear();
        }
        for (const auto& val : vals)
            doSomething(val);
    }
}

void producer() {
    while (active) {
        {
            std::unique_lock<std::mutex> l(m);
            q.push_back(produce());
        }  
        cv.notify_one();
   }
}