disruptor-pattern

23熱

2答えて

Disruptor.NETメッセージングフレームワークを使用する方法を学習しようとしていますが、実用的な例は見つかりません。どのように動作するかについての写真が載っている記事がかなりありますが、実際にどこに行っても見つからず、メソッドを実装する方法を示しています。例は何でしょうか？

2熱

1答えて

このJavaアプリケーションはスレッドを拡張せずに複数のスレッドを実行していますか？

私はJavaを学び、runnableを使って既存のアプリで多少のマルチスレッドを行うことができました。私は現在、スレッド間で変数を共有するために混乱を見ていましたが、スレッドが実際にどのようにスレッドを生成しているのかわかりません。彼は私のプログラムで実行可能クラスを送信するために使用するExecutorを使用していますが、この例ではサブミット（または実行可能）はありません。私はOracleのチ

1熱

1答えて

Java Future.get（）が返さない

以下のコードまたはValueMutationEventHandlerからfuture2get（）を実行してfuture2の完了を待ってから結果を取得できないのはなぜですか？ future2.get（）を実行すると、永遠に待機します。 import java.util.concurrent.BrokenBarrierException; import java.util.concurren

4熱

2答えて

Java：Disruptor：DisruptorはPODデータ型に対してのみ使用する必要がありますか？

DisruptorはPODデータ型にのみ使用する必要がありますか？ Disruptor<T>は、byte[], int[], etcのような値を取るためにのみ使用してください。 Tのメンバー変数をObjectとすると、ヒープ上にあるnewのメンバ変数が必要になります。これは、メンバ変数がヒープの完全に別の部分にあるため、キャッシュミスを招きます。 Disruptor<T>は、Plain Old

27熱

2答えて

Disruptor（Disruptor Pattern）を使用して実際のメッセージシステムを構築するにはどうすればよいですか？

RingBuffer up-frontは、指定された型のオブジェクトを割り当てるので、単一のリングバッファを使ってさまざまな種類のメッセージを処理するにはどうすればよいですか？ ringBufferに挿入するために新しいオブジェクトインスタンスを作成することはできません。これは、前払い割り当ての目的を無効にします。ですから、非同期メッセージングパターンで3メッセージを持つことができます： New

4熱

1答えて

LMAX DisruptorをC＃に移植できますか？

C++ポートで作業している人がいることは知っています。 C＃ポートは使用できますか？特に、私はC＃で32ビットしかない揮発性フィールドの制限について考えています。これが唯一の問題であれば、32ビットで許容されるスロット数だけを持つリングバッファを書く価値があると思いますか？それは、システムの寿命の中で、ずっと多くの事象であります。私はこの権利を持っていますか？ある時点で0に折り返すことはできますか

1熱

1答えて

LMAX Disruptor Queueにタイムアウト機能を適用するにはどうすればよいですか？ LMAXかく乱<a href="http://code.google.com/p/disruptor/" rel="nofollow">http://code.google.com/p/disruptor/</a>の開発者/ユーザーへ

：私の質問：誰がかく乱などにタイムアウト機能を適用する方法へのアプローチを提案することができますEventHandlerを使用していますか？ここでが仕事の私のラインに来た1つのシナリオです： - ネットワーク上のサーバーに送信されたメッセージ受信トレイ - 送信トレイACKメッセージは、サーバー ACKハンドラから受け取りました - マークがACKさタイムアウトハンドラとしてメッセージを