我有一个线程池,它由4个线程组成: t1、t2、t3和t4。它们同时运行,但是来自t3和t4的输入取决于来自t2的输出。我应该如何实现消息队列,以便在t2完成后,它将输出数据发送到t3和t4进行处理?我尝试过使用锁定机制来实现消息队列,但是锁的开销似乎很大。是否存在在线程之间传递数据的无锁机制?我正在使用boost::线程在2010中。
发布于 2014-11-19 09:38:22
Boost有一个无锁队列:0/doc/html/lockfree.html。
发布于 2014-11-19 09:55:18
您可以考虑tbb。它提供了广泛的并行概念,包括concurrent_queue
、concurrent_bounded_queue
(用于等待)、pipeline
、flow::graph
。前两个版本也可以在MS 2010的ppl中使用。
https://stackoverflow.com/questions/27013348
复制相似问题