CompleteableFutureを使用して、バッチインターフェイスの順序を確保し、結果を効率的に処理する方法

Java Concurrentプログラミング：CompleteableFutureを使用して、バッチインターフェイスリクエストを効率的かつ整然と処理する

サードパーティのインターフェイスへの同時アクセスが高いと、データ処理効率が大幅に向上する可能性がありますが、スレッドの実行順序が制御されていない場合、最終結果は元のデータ順序と一致しないため、その後の処理エラーが発生します。この記事では、Javaの完全な財政を使用して、マルチスレッド環境でインターフェイスリクエストと結果の整然とした処理を確保する方法を紹介します。

問題： CompletableFuture.runAsyncを直接使用して、非同期呼び出しを行います。スレッド実行の予測不可能な順序により、返された結果は元のデータリストの順序と矛盾しています。 CompletableFuture.allOf 、すべてのタスクの完了のみを保証でき、注文は保証できません。

解決策：結果を返すCompletableFuture.supplyAsyncを使用します。各非同期タスクのリターン結果をCompletableFuture<string></string>に備えて保存しますCompletableFuture<string></string>リストでは、すべてのタスクが完了した後、結果はstream().map(CompletableFuture::join).collect(Collectors.toList())を介して元の順序で収集されます。

改善されたコードの例：

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

    executorservice executorservice = new ThreadPoolexecutor（
            10、// corepoolsize
            20、// maximumpoolsize
            60L、// KeepAlivetime
            TimeUnit.seconds、
            新しいLinkedBlockingQueue （1024）、// workqueue
            新しいthreadpoolexecutor.callerrunspolicy（）//ハンドラー
    ）;

    リスト<completablefuture> > futures = new ArrayList （）;
    for（string data：datalist）{
        futures.add（completeablefuture.supplyasync（（） - > {
            logger.info（ "処理データ：{}"、data）;
            //サードパーティインターフェイスを呼び出してデータを処理します
            // ...インターフェイスコールと結果の処理ロジック...
            データを返す " - 処理された結果"; //処理結果を返す}、executorservice））;
    }

    completeablefuture.allof（futures.toarray（new completeablefuture [0]））。thenrun（（） - > {{{
        リスト<string> 結果= futures.stream（）
                .map（completeablefuture :: join）
                .collect（collectors.tolist（））;
        logger.info（ "すべてのタスクが完了しました。結果：{}"、json.tojsonstring（results））;
        //後続の処理結果}）
}</string></completablefuture></string>

改良されたコードは、 CompletableFuture.supplyAsyncを使用して各インターフェイスコールの結果を返し、 futuresリストに保存されます。 CompletableFuture.allOf 、すべてのタスクが完了した後に結果が処理されることを保証します。 stream().map(CompletableFuture::join).collect(Collectors.toList())結果が元の順序で収集されることを保証し、結果の順に同時性の問題を解決します。コードは、リソースの使用をよりよく制御するために、カスタムスレッドプールも使用します。

以上がCompleteableFutureを使用して、バッチインターフェイスの順序を確保し、結果を効率的に処理する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。