厳密な順序でのメッセージの並行処理

Question

JavaEE Webアプリケーション内では、着信メッセージを厳密に到着順に処理する必要があります。 Webappコンテナ（Tomcat 6）は、httpポートに到着するメッセージの順序を保持していると仮定します。

私に頭痛を引き起こす原因は、これらのメッセージを内部的に処理する方法です。作業負荷を改善するために、ここでは多くのことを行う必要があるため、各メッセージの処理をThreadPoolに追加します。 XML解析、時には外部Webサービスを使用したデータの充実処理が終了したら、メッセージのJava表現を複合ストリーム処理エンジンesper.codehaus.orgにプッシュします。これはスレッドセーフです。ここでは、入射順序が最も高い要件、例えば現象の閾値を超える場合に、異なるパターンがチェックされる。

到着時に受け取った優先度ID（各サーブレットでは、メッセージごとにインクリメントされる）で処理されたすべてのメッセージをPriorityQueueに挿入するという考えがありました。

キューから要素をポーリングしているスレッド（最下位のIDがキューの先頭です）は、エスペアに挿入するために、欠落している項目をチェックしないためIDをスキップできます。私はイラストが良くうまくいくと思います：（4）すべてが意図したとおりに動作する手順（1）については

。しかし、ステップ（5）において、QueuePollerは、エレメント6を検索し、エレメント4は検索しない（ステップ（6）で後に挿入される）。メッセージの順序は次のようになります。 3; 6; 4.

私が試みたのは、厳密なIDの順序に従ってキューの頭をポーリングする実装を変更することでした。つまり、次のIDの要素がまだキューに挿入されていない場合は、その時点までバリアを待ちます。これは最初の10分間は機能していたようですが、おそらくキューに挿入されなかった要素が原因でハングしました。

これまで誰かが同じような問題を抱えていて、私にはいくつかのヒントがありますか？

Answer 1

Disruptorをチェックアウト - 高性能キューを厳密な順序で（最初に入力した - 最初の務め）

Answer 2

をクラスライブラリには、いくつかの有用な事前に定義された構成とともに、柔軟なスレッドプールの実装を提供します。 Executorの静的ファクトリメソッドの1つを呼び出して、スレッドプールを作成することができます。

私はExecutors.newSingleThreadExecutor（）が最適だと思います。シングル・スレッド・エグゼキュータは、タスクを処理するための単一のワーカー・スレッドを作成し、予期せず終了した場合にはそれを置き換えます。タスクは、タスクキュー（FIFO、LIFO、優先順位）によって課された順序に従って順次処理されることが保証されています。

Answer 3

あなたの問題と、ダイアグラムの必要性（そのために+1）からわかるように、プライオリティキューは、あなたが望むもののための良い構築物ではありません。これは、キューが利用できなくなるのを待つのではなく、利用可能な6を提供することが完全にうれしいからです。

自分の同期コンテナをロールするときが来たと思います。

Answer 4

着信要求のプレースホルダーを即時に処理キューに追加できます。プレースホルダはスレッドプールによってバックグラウンドで前処理されますが、メイン処理は前処理が完了するのを待ちます。私が考えている構成はFutureです。