Java マルチスレッド非同期呼び出しのパフォーマンスを調整する方法

大手電子商取引企業の支払い集約サービスはすべて、次のようなシナリオを持っています:

• 検証サービスを呼び出して、生成される注文が合法かどうかを確認します

##注文サービスは注文を生成します (検証サービスと注文サービスには依存関係がありません) )
呼び出し 1 と 2、支払いサービスは支払いコア機能を実装します
ステップ 1 から 3 を組み合わせて、支払いサービス
ステップ 1 に 5 秒かかり、ステップ 2 に 3 秒かかり、ステップ 3 に 2 秒かかる場合、アーキテクトの場合、要件は次のとおりです。

1. マイクロサービス Call の同期を実装してください

2. マイクロサービスの非同期呼び出しを実装してください (CompletableFuture を使用して実装)

1 と 2 のパフォーマンスを比較してください。

同期呼び出しと非同期呼び出し

Future クラス図

#Future の欠点

#Future には多くの直接的な式があります Future の結果間の依存関係には特定の欠陥があります:

public class Test {
    public static void main(String[] args) {
    	// 同步调用
        long start1 = System.currentTimeMillis();
        PaymentService.syncPay();
        System.out.println("同步支付耗时:" + (System.currentTimeMillis() - start1)+" ms");
        System.out.println("=========================");
        // 异步调用
        long start2 = System.currentTimeMillis();
        PaymentService.asyncPay();
        System.out.println("异步支付耗时:" + (System.currentTimeMillis() - start2)+" ms");
    }
}

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
public class PaymentService {
    /**
     * 异步支付的入口方法
     *
     * @return
     */
    public static boolean asyncPay() {
        //校验
        CompletableFuture<Boolean> isValid = CompletableFuture.supplyAsync(() -> CheckService.isValid());
        //创建订单
        CompletableFuture<Integer> orderSum = CompletableFuture.supplyAsync(() -> OrderService.createOrder());
        //支付
        CompletableFuture<Integer> money = CompletableFuture.supplyAsync(() -> basePay());
        // 上面三个都完成之后,再进行下面匿名内部类的代码
        CompletableFuture.allOf(isValid, orderSum, money)
                .thenRun(() -> System.out.println("完成异步支付"))
                .join();
        return true;
    }
    /**
     * 同步支付的入口方法
     *
     * @return
     */
    public static boolean syncPay() {
        CheckService.isValid();
        OrderService.createOrder();
        basePay();
        System.out.println("同步支付成功");
        //假设支付成功
        return true;
    }
    public static int basePay() {
        int money = 1000;
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("支付");
        //假设支付成功
        return money;
    }
}

ログイン後にコピー

import java.util.concurrent.TimeUnit;
public class CheckService {
	/**
	 * 返回true说明订单流程才会往下走
	 */
    public static boolean isValid() {
        System.out.println("订单生成前，检验订单是否合法" );
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //假设订单合法，通过校验
        return true;
    }
}

ログイン後にコピー

import java.util.concurrent.TimeUnit;
public class OrderService {
    public static int createOrder() {
        int orderSum=1;
        System.out.println("生成订单" );
        try {
            TimeUnit.SECONDS.sleep(3);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //假设订单数量为1
        return orderSum;
    }
}

ログイン後にコピー

以上がJava マルチスレッド非同期呼び出しのパフォーマンスを調整する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。