Java8 使用工厂方法supplyAsync创建CompletableFuture实例

public Future<Double> getPriceAsync(String product) {
	return CompletableFuture.supplyAsync(() -> calculatePrice(product));
}

public Future<Double> getPriceAsync(String product) {
	return CompletableFuture.supplyAsync(() -> calculatePrice(product));
}

public Future<Double> getPriceAsync(String product) {
	CompletableFuture<Double> futurePrice = new CompletableFuture<>();
	new Thread( () -> {
		try {
			double price = calculatePrice(product);
			futurePrice.complete(price);
	} catch (Exception ex) {
			futurePrice.completeExceptionally(ex);
	}
	}).start();
	return futurePrice;
}

ExecutorService executorService = Executors.newFixedThreadPool(3);
        //executorService.submit(new RuleTestRunnable(1));
        List<Integer> taskList = new ArrayList<>();
        for (int i = 0; i < 30; i++) {
            taskList.add(i);
        }
        CompletableFuture<String> a1 = CompletableFuture.supplyAsync(() -> {
            logger.info("线程1{}{}","开始");
 
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info("线程1{}{}","结束");
            return "1";
        },executorService);
       CompletableFuture<String> a2 = CompletableFuture.supplyAsync(() -> {
 
            logger.info("线程2{}{}","开始");
            try {
                TimeUnit.MILLISECONDS.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info("线程2{}{}","结束");
            return "1";
        },executorService);
        CompletableFuture<Object> a= a1.thenCombineAsync(a2,(s1,s2) -> {
            logger.info("组合线程{}{}");
            return  s1+s2;
        },executorService);
        Object result = a.get();