SafeQueue:C++ 中的线程安全队列实现

时间:2024-06-19 09:12:16
【文件属性】:

文件名称:SafeQueue:C++ 中的线程安全队列实现

文件大小:2KB

文件格式:ZIP

更新时间:2024-06-19 09:12:16

queue cpp thread-safe thread-safe-queue C++

安全队列 这个类是一个多生产者、多消费者队列。 它同时提供阻塞和非阻塞消费,而生产总是阻塞。 容量是动态调整的。 实现基于std::queue ,使用std::mutex和std::condition_variable实现线程安全。 可以使用右值引用调用Produce(T&& item)函数。 Consume(T& item)函数立即返回一个布尔值,表示成功。 ConsumeSync(T& item)方法将阻塞调用线程,直到它可以从队列中取出一个项目。 Finish方法停止所有等待的消费者 (ConsumeSync),并使它们返回 false。 例子 制作人: SafeQueue queue; // insert elements queue.Produce(std::move(var1)); queue.Produce(std::move(var2)); 非阻塞消费


【文件预览】:
SafeQueue-master
----LICENSE(1KB)
----SafeQueue.hpp(1KB)
----README.md(1KB)

网友评论