java - 在 Fibers Quasar 之间传递消息

Question

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

我应该实现这个接口(interface)吗？

我对光纤间通信的理解完全错误吗？

Answer 1

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

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