私たちのアプリケーション統合フローは、スプリッター -> ws ゲートウェイ -> アグリゲーターとして定義されています。スプリッターはリクエストをアカウント番号のリストに分割します。アカウント番号ごとに Web サービス呼び出しが開始され、複数の Web サービス呼び出しからの応答がアグリゲーターに集約されます。異なるスレッド。
各 Web サービス呼び出しにタイムアウトを追加しました。しかし、プロセス全体に対して単一のタイムアウトを設定したいと考えています。つまり、すべての Web サービス呼び出しは、個々の呼び出しごとに 50 秒のタイムアウトを設定するのではなく、たとえば 50 秒で完了する必要があります。commonj WorkManagerTaskExecutor は、コードを介して直接実装された場合、waitForAll(Collection workItems, long timeout_ms) メソッドによってこの機能を提供します。この機能または同様の機能を使用して要件を達成する方法はありますか?