使来自线程的数据流对所有其他线程都可读

Question

我必须在多线程服务器实例的客户端下分发数据流，客户端线程只需要读取。这意味着我有一个数据来自的线程，所有其他线程都需要读取该数据（他们不必再更改它），以便他们可以将数据发送给客户端。

我尝试了一个线程安全队列 (https://blog.chrisd.info/a-simple-thread-safe-queue-for-use-in-multi-threaded-c-applications/)，但是当我尝试使用多个客户端时，只有第二个或新的客户端接收到数据。

我该如何解决这个问题？是否有可以在多个线程中使用的线程安全队列？

卢克

Answer 1

正如您所描述的，通常的队列语义将不起作用，因为您实际上希望在所有线程都获得元素时弹出元素，而不是在第一次访问时。所以你有几个选择：

• 为每个客户端线程维护一个队列，生产者线程始终将数据推送到每个客户端线程。通过将数据包装到 std::shared_ptr 中，您可以减少内存开销并创建语义，当最后一个客户端完成数据时，数据将被销毁。
• 有一个队列，但每个线程有多个尾指针。尽管在线程产生/终止时处理线程可能会变得复杂。但是您还没有说明系统中的限制条件 - 线程数是固定的还是动态的。