0

でメッセージを聞いて処理するために、クエーサー ファイバーを使用していますQueueObjectChannel。ファイバー間のメッセージ キューとしてどのオブジェクトを使用すればよいかわかりません。私が抱えている問題は、QueueObjectChannelコンストラクターに渡されるはずのものを理解していないことです。javadoc によると、コンストラクターは取ることになっていますQueueObjectChannel(co.paralleluniverse.strands.queues.BasicQueue<Message> queue, Channels.OverflowPolicy policy, boolean singleProducer, boolean singleConsumer)が、実装するものを構築しようとしているため、直感に反するようですBasicQueue。

インターフェイスを実装することになっていますか？

ファイバー間通信に対する私の理解は完全に間違っていますか?

4

1 に答える 1

1

通常、バッキング キューではなく、チャネル API を使用したい (そして使用する必要があります)。たとえば、異なるキューの実装は、単一のコンシューマーがある場合など、特定のバッファー構成を使用する、スレッドやファイバーを使用する、一部のデータ型でのみ機能および/または最適化されます。

ここで説明したように、必要なプロパティを渡す静的Channels.new*Channelメソッドを使用するだけで、ユースケースに合わせて調整されたキューによってサポートされるチャネルを取得できます。

于 2016-02-08T08:49:14.807 に答える