Java多執行緒異步呼叫效能如何調優

概述

大型電商公司的支付聚合服務都有這類的場景:

• 呼叫校驗服務校驗待產生的訂單是否合法

• 訂單服務產生訂單(校驗服務和訂單服務沒有依賴關係)

• #呼叫1和2,支付服務實作支付核心的功能

• 結合步驟1至3完成支付服務的聚合呼叫

#假如步驟1的耗時5秒,步驟2的耗時3秒,步驟3的耗時2秒,如果你是架構師,要求:

1.請實現微服務的同步呼叫

2.請實作微服務的非同步呼叫(使用CompletableFuture實作)

比較1和2的效能.

同步呼叫和非同步呼叫

#Future類別圖

Future的不足

Future直接表述多個Future結果之間的依賴性,有一定的缺陷:

1.將兩個非同步計算合併為一個(第二個非同步計算依賴於第一個的結果),這個用Future不太好實現.

2.等待Future集合中的所有的任務都完成

僅等待Future集合中最快結束的任務完成,並返回它的結果

程式碼

程式碼位址

https://gitee.com/zjvngvn/mutil-thread

Test

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");
    }
}

PaymentService

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;
    }
}

CheckService

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;
    }
}

OrderService

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中文網其他相關文章！