2017-09-30 11 views
0

私は5つのタスクを持っています。これらのタスクはパラレルに実行する必要があります。 5つの異なるクラスでこのタスクの実装。今私はこれらの5つのクラスを並列に呼び出す必要があります。また、呼び出しごとに実行されるタスクの回数も異なります。スプリングインテグレーションを使用して並列呼び出しのリストを作成することは可能ですか

私は、実行するタスクのリストを提供するProcessExecuoterクラスを持っていると言います。

//このリストは、各呼び出しを動的に変更します。 List myTaskList = new ArrayList();

MyTaskのプロパティ値に基づいて、対応するTaskClassを呼び出して結果を収集する必要があります。

私はSpring Boot 1.2.4とJava 1.6を使用しています。

答えて

0

メッセージのペイロードとしてタスクをExecutorChannelに送信し、後でAggregatorコンポーネントを使用して結果を収集する必要があります。

あなたはリファレンスマニュアルで見つけることができるすべての必要な情報:

https://docs.spring.io/spring-integration/docs/4.3.12.RELEASE/reference/html/messaging-channels-section.html#executor-channel

https://docs.spring.io/spring-integration/docs/4.3.12.RELEASE/reference/html/messaging-routing-chapter.html#aggregator

+0

はないaggreagtor私はすべてのスレッドの実行が完了する呼び出されるか、我々は任意のプロパティを設定する必要がありますか?すべての結果がアグリゲーターによって収集されていることを確認してください。 – springbootlearner

関連する問題