lmax

2熱

2答えて

Lmax Disruptor、多くの消費者 - どのようにして消費者を特定の種類のメッセージにして、独立して進めるのか？

私は混乱の中で多くの並列消費者を持つことを計画しています。 各消費者は、それらのためのメッセージを消費する必要があります。例えば 、IはタイプA、B、Cのメッセージを持っていると私はタイプごとに消費者を有する #1 - type A, #2 - type B, #3 - type C, #4 - type A, #5 - type C, #6 - type C, (and so on) ように

java concurrency disruptor-pattern lmax 2017-04-12

---

2熱

1答えて

LMAX DisruptorはAndroidで動作しますか？

AndroidでLMAX Disruptorを使用している人はいましたか？それは動作し、互換性の問題はありますか？

android disruptor-pattern lmax 2016-05-05

---

0熱

1答えて

LMAX Disruptor（unmarchalerからビジネスロジックまで）の下位層のコンシューマ間でデータを渡す？

https://martinfowler.com/articles/lmax.htmlで説明したように、私はRingBufferのイベントをまずUnmarchalerで処理し、次にBusiness Logic Processorで処理する必要があります。 Disruptor<MyEvent> disruptor = new Disruptor<MyEvent>(MyEvent.FACTORY, 3

disruptor-pattern lmax 2017-01-18

---

2熱

1答えて

lmaxディスラプター内の処理を一時停止しますか？

私はLmaxをかく乱使用して性能試験を行いたいと思います： 設定のdusruptor どういうわけか「一時停止」 がリングバッファ 「一時停止を解除」処理 に多くのメッセージを追加処理 このようにして、バッファがどれだけ空になったかをきれいに測定できました。多くのメッセージ（遅延を導入する）を追加して処理すると、処理速度が低下することがあります。 私はLMAX Disruptor（https://

disruptor-pattern lmax 2017-01-26

---

2熱

1答えて

EventHandler onEventのLMAXディスラプタータイムアウト

私はリングバッファーとイベントハンドラーを持っています。これは、メッセージングサーバーのインバウンドバッファとして使用されます。 私の偶数ハンドラの中では、いくつかのAMQPサービス呼び出しを行いますが、その呼び出しがタイムアウト（AMQPサービスを呼び出すアンダーラインプロトコルライブラリのバグ）を待たずに何度か待機します。そして、2000tpsで、これは私の4096サイズのリングバッファをFU

disruptor-pattern lmax 2016-04-07

---