C# BlockingCollection 的 c++/boost 模拟？

Question

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

BlockingCollection 的 c++/boost 模拟是什么？

Answer 1

你可以使用 boost::lockfree库以实现所需的行为。 在这种情况下，您可以在 pop 方法之上实现 Take 和 TryTake。

或者您可以使用 this answer用 std::mutex 和 std::condition_variable 保护 std::deque(用 C++11 编写的答案，但你可以使用 boost::thread 访问来自旧编译器的线程相关内容)。

更新

实际上我不推荐第一种方法因为它扼杀了无锁容器的整个想法:) 所以，对于第二种情况TryTake (tryPop)可以用下面的代码实现(只是例子)

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));