我正在使用类星体光纤来监听和处理QueueObjectChannel上的消息。我不知道我应该使用哪个对象作为光纤之间的消息队列。我遇到的问题是,我不明白应该将什么传递到QueueObjectChannel构造函数中。根据javadoc,构造函数应该采用QueueObjectChannel(co.paralleluniverse.strands.queues.BasicQueue<Message> queue, Channels.OverflowPolicy policy, boolean singleProducer, boolean singleConsumer),但这似乎有悖常理,因为我正在尝试构建实现BasicQueue的东西。
我应该实现这个接口吗?
我对光纤通信的理解完全错误吗?
发布于 2016-02-08 08:49:14
通常人们希望(并且应该)使用通道API,而不是支持队列。例如,不同的队列实现只能在某些数据类型、线程和/或光纤、具有特定缓冲区配置的情况下才能工作和/或优化,当存在单个使用者时,等等。
由于在此解释只使用传入所需属性的静态方法,您将得到一个由适合您的用例的队列支持的通道。
https://stackoverflow.com/questions/35166924
复制相似问题