サマライザーを構築していて、パイプラインの実装が必要です。私は独自の実装を使用しましたが、作業が大きくなるにつれて、それではうまくいかないことがわかりました。
基盤 (基本的には同期ロジック) を提供する Java の成熟したフレームワークはありますか?
ステージを宣言する必要があり、各ステージにはワーカーがあり、ワーカーはアイテムを処理して結果をステージに返し、ステージはそれを次のステージに送信します (ファンアウトする可能性があります)。
私の実装の要点は、この基盤を提供することでしたが、適切に機能しません (デッドロックをもたらす競合状態)
apache ライブラリ (基本的には死んでいます) を取得しようとしましたが、ステージ ワーカーを作成する機能がありません。