完了Futureを使用して、バッチインターフェイス要求の結果の順序一貫性を確保する方法は？

バッチインターフェイスリクエストの効率的な同時処理：結果の順序が一貫していることを確認してください

複数のサードパーティインターフェイスへの同時呼び出しは、大量のデータを効率的に処理する際に効率を大幅に改善できます。ただし、単純なマルチスレッドの並行性により、戻り結果の順序が一貫性がなく、元のデータリストに対応しない場合があります。この記事では、JavaのCompletableFuture財政を使用してこの問題を解決する方法を紹介し、インターフェイスコールの結果が元のデータ順序とまったく同じであることを確認します。

質問：

1000を超えるサードパーティインターフェイスを同時に呼び出し、処理して結果を返す必要があるとします。複数のスレッドがループforシンプルを使用して開始された場合、インターフェイス呼び出しの順序は保証できず、最終結果の順序は元のデータリストと一致しません。一部のサンプルコードは、 CompletableFuture.runAsyncを使用して非同期タスクを実行しますが、結果の収集と順次のメンテナンスは無視します。

解決：

結果の順序が元のデータリストと一致するようにするために、重要なのは、 CompletableFuture.supplyAsyncの代わりにCompletableFuture.runAsync future.supplyasyncを使用することです。 supplyAsyncメソッドは結果を返すことができますが、 runAsync値を返しません。 supplyAsyncを介して各インターフェイスコールの結果を返し、プロセスをストリーミングして結果をリストに収集して、結果の順序が元のデータリストと一致していることを確認します。

改善されたコード：

 public static void main（string [] args）{
    リスト<string> datalist = new ArrayList （）; //元のデータリスト// ... Datalistを初期化...

    executorservice executorservice = new ThreadPoolexecutor（
            //コアスレッドの数runtime.getRuntime（）。利用可能なプロセッサ（）、
            //スレッドの最大数runtime.getRuntime（）。利用可能なプロセッサ（） * 2、
            //スレッドサバイバル時間60L、TimeUnit.seconds、
            新しいLinkedBlockingQueue （）、
            新しいthreadpoolexecutor.callerrunspolicy（））;

    リスト<completablefuture> > futures = new ArrayList （）;
    for（string data：datalist）{
        futures.add（completeablefuture.supplyasync（（） - > {
            logger.info（ "非同期スレッドの実行を開始 -  >>"データ）;
            //インターフェイスを呼び出してデータを渡します
            //インターフェイスの返信値に基づいてデータが一致するかどうかを判断します//データを処理して結果を返します}、executorservice））; //カスタムスレッドプールを使用}

    //完了したすべてのリクエストのロジックを処理した後、completable future.allof（futures.toarray（new completeablefuture [0]））。thenrun（（） - > {{
        リスト<string> 結果= futures.stream（）
                .map（completeablefuture :: join）
                .collect（collectors.tolist（））;
        logger.info（ "スレッド実行が完了しました：{}"、json.tojsonstring（results））;
        // sms}を送信する}）
}

//データの処理方法、プライベート静的文字列ProcessData（String Data）を変更する{
    // ...インターフェイスコールとデータ処理ロジック...
    データ「処理済み結果」を返します。
}</string></completablefuture></string>

futuresリストに各CompletableFutureの結果を保存しfutures.stream().map(CompletableFuture::join).collect(Collectors.toList())を使用して結果を収集することにより、結果順序が元のデータリストと一致するようになります。 CompletableFuture::join CompletableFutureの結果が得られるまで、メソッドブロックに参加します。これは、元のコードで一貫性のない結果の問題を効果的に解決します。

以上が完了Futureを使用して、バッチインターフェイス要求の結果の順序一貫性を確保する方法は？の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。