在光纤 Quasar 之间传递消息

Question

我正在使用类星体光纤来收听和处理QueueObjectChannel 上的消息。我不确定我应该使用什么对象作为光纤之间的消息队列。我遇到的问题是我不明白应该将什么传递给QueueObjectChannel 构造函数。根据javadoc，构造函数应该采用QueueObjectChannel(co.paralleluniverse.strands.queues.BasicQueue<Message> queue, Channels.OverflowPolicy policy, boolean singleProducer, boolean singleConsumer)，但这似乎违反直觉，因为我正在尝试构建实现BasicQueue的东西。

我应该实现接口吗？

我对光纤间通信的理解完全不正确吗？

Answer 1

通常人们想要（并且应该）使用通道 API，而不是后备队列。例如，不同的队列实现只能在某些数据类型、线程和/或光纤、特定缓冲区配置、单个消费者等情况下工作和/或最佳。

作为explained here，只需使用静态Channels.new*Channel methods 传递您需要的属性，您将获得一个由适合您的用例的队列支持的通道。