java - 在光纤 Quasar 之间传递消息

Question

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

我应该实现接口吗？

我对光纤间通信的理解完全关闭了吗？

Answer 1

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

正如这里所解释的，只需使用传递您需要的属性的静态Channels.new*Channel方法，您将获得一个由适合您的用例的队列支持的通道。