C++/Boost模拟C#BlockingCollection？

Question

我喜欢C#线程安全的BlockingCollection，它允许我使用Take和TryTake方法“阻止”直到新项目可用，例如阻止最大值1秒:OrderActions.TryTake(out oa,1000）；

什么是blockingcollection的C++/boost模拟？

Answer 1

您可以使用Boost：：LockFree库来实现所需的行为。在这种情况下，您可以在pop方法之上实现take和trytake。

或者，您可以使用此答案，使用std::mutex和std::condition_variable来保护std::deque（答案是用C++11编写的，但您可以使用boost::thread从旧的编译器访问线程相关的内容）。

更新

template<typename PeriodT>
bool tryPop (T & v, PeriodT dur) {
    std::unique_lock<std::mutex> lock(this->d_mutex);
    if (!this->d_condition.wait_for(lock, dur, [=]{ return !this->d_queue.empty(); })) {
        return false;
    }
    v = std::move (this->d_queue.back());
    this->d_queue.pop_back();
    return true;
}    

例如，periodt可以是std::chrono::milliseconds。快速示例：

queue<int> p;
int v;
p.tryPop (v, std::chrono::milliseconds(1));