c++ - 在 C++ 中获取一个只有一次有效的锁

Question

我使用的是 C++ 11，其中有 4 个并行插入并发队列的线程。我知道线程何时完成处理，即队列的预期最终大小。

现在，我想对队列的内容执行最终的聚合操作，该操作应该严格仅执行一次。例如，假设我想聚合值并将其发布到外部服务。

如何获得一个只有一次有效的锁？我不能使用简单的互斥锁，因为这不能保证我只需要一次。

伪代码:

// inside a thread
enqueue items to concurrent_queue

if(concurrent_queue.size() == EXPECTED_SIZE) {
    // do something ONLY once
}

Answer 1

一个简单的解决方案。

if(concurrent_queue.size() == EXPECTED_SIZE) {
    // do something ONLY once
    static bool doItOnce = DoItOnceOnly();
}