public class Test {
    public static void main(String[] args) {
    	// 同步調(diào)用
        long start1 = System.currentTimeMillis();
        PaymentService.syncPay();
        System.out.println("同步支付耗時:" + (System.currentTimeMillis() - start1)+" ms");
        System.out.println("=========================");
        // 異步調(diào)用
        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());
        //創(chuàng)建訂單
        CompletableFuture<Integer> orderSum = CompletableFuture.supplyAsync(() -> OrderService.createOrder());
        //支付
        CompletableFuture<Integer> money = CompletableFuture.supplyAsync(() -> basePay());
        // 上面三個都完成之后,再進行下面匿名內(nèi)部類的代碼
        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("同步支付成功");
        //假設(shè)支付成功
        return true;
    }
    public static int basePay() {
        int money = 1000;
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("支付");
        //假設(shè)支付成功
        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();
        }
        //假設(shè)訂單合法，通過校驗
        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();
        }
        //假設(shè)訂單數(shù)量為1
        return orderSum;
    }
}