摘要：所以很容易出現(xiàn)某一個商店的數(shù)據(jù)遲遲無法返回的情況。工廠方法接受由對象構成的數(shù)組數(shù)組中所有的完成后它返回一個對象。異步的可以通過進行合并，無論他們之間是否有依賴關系?？梢詾樽砸粋€回調(diào)函數(shù)，在執(zhí)行完畢時使用。

由于我們的兩個遠程服務：1.查詢價格，2.查詢折扣價格都是基于網(wǎng)絡的。所以很容易出現(xiàn)某一個商店的數(shù)據(jù)遲遲無法返回的情況。由于這些原因，我希望查詢器在查詢時能夠?qū)⒛玫綌?shù)據(jù)先返回過來，而不是等待所有的異步查詢完成后集中返回一個List。
我們首要需要避免的就是：等待創(chuàng)建一個包含所有價格的List。我們應該直接處理CompletableFuture流，然后去響應他的completion事件，每一個CompletableFuture對象完成時獲取到相應的返回值。

先將Discount的折扣服務延遲時間修改為隨機值：

    //計算折扣價格
    private static Double apply(double price ,Code code){
        //模擬遠程操作的延遲
        delay();
        return (price * (100 - code.percantage)) / 100;
    }
    private static void delay(){
        try {
            //隨機延遲時間
            int delay = 500 + random.nextInt(2000);
            Thread.sleep(delay);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

開始實現(xiàn)最佳價格查詢器：

package BestPriceFinder;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * 最佳價格查詢器
 */
public class BestFinder {

    List shops = Arrays.asList(
            new Shop("A"),
            new Shop("B"),
            new Shop("C"),
            new Shop("D"),
            new Shop("E"),
            new Shop("F"),
            new Shop("G"),
            new Shop("H"),
            new Shop("I"),
            new Shop("J")
    );

    public void findPricesContinue(String product){
        long st = System.currentTimeMillis();
        Stream> futurePrices = shops.stream()
                //首先異步獲取價格
                .map(shop -> CompletableFuture.supplyAsync(() -> shop.getPriceFormat(product),myExecutor))
                //將獲取的字符串解析成對象
                .map(future -> future.thenApply(Quote::parse))
                //使用另一個異步任務有獲取折扣價格
                .map(future -> future.thenCompose(quote -> CompletableFuture.supplyAsync(() -> Discount.applyDiscount(quote),myExecutor)));
        //thenAccept()會在CompletableFuture完成之后使用他的返回值，這里會持續(xù)執(zhí)行子線程
        CompletableFuture[] futures = futurePrices.map(f -> f.thenAccept(s -> {
                                                                            String sout = String.format("%s done in %s mesc",s,(System.currentTimeMillis() - st));
                                                                            System.out.println(sout);
                                                                         }))
                                                  .toArray(size -> new CompletableFuture[size]);
        //allOf()工廠方法接受由CompletableFuture對象構成的數(shù)組，這里使用其等待所有的子線程執(zhí)行完畢
        CompletableFuture.allOf(futures).join();
    }

  

    /**
     * 異步查詢
     * 相比并行流的話CompletableFuture更有優(yōu)勢：可以對執(zhí)行器配置，設置線程池大小
     */
    @SuppressWarnings("all")
    private final Executor myExecutor = Executors.newFixedThreadPool(Math.min(shops.size(), 100), new ThreadFactory() {
        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
            //使用守護線程保證不會阻止程序的關停
            t.setDaemon(true);
            return t;
        }
    });
   

thenAccept()：提供了在CompletableFuture對象完成后使用他的返回值的功能。這樣我們的每一個CompletableFuture完成后就會打印他的返回值，最終等待所有的子線程完畢。

allOf():工廠方法接受由CompletableFuture對象構成的數(shù)組,數(shù)組中所有的CompletableFuture完成后它返回一個CompletableFuture對象。

anyOf():廠方法接受由CompletableFuture對象構成的數(shù)組,返回數(shù)組中第一個完成的CompletableFuture的返回值CompletableFuture