摘要：所以很容易出現(xiàn)某一個(gè)商店的數(shù)據(jù)遲遲無(wú)法返回的情況。工廠方法接受由對(duì)象構(gòu)成的數(shù)組數(shù)組中所有的完成后它返回一個(gè)對(duì)象。異步的可以通過(guò)進(jìn)行合并，無(wú)論他們之間是否有依賴關(guān)系。可以為注冊(cè)一個(gè)回調(diào)函數(shù)，在執(zhí)行完畢時(shí)使用。

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

先將Discount的折扣服務(wù)延遲時(shí)間修改為隨機(jī)值：

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

開(kāi)始實(shí)現(xiàn)最佳價(jià)格查詢器：

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;

/**
 * 最佳價(jià)格查詢器
 */
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()
                //首先異步獲取價(jià)格
                .map(shop -> CompletableFuture.supplyAsync(() -> shop.getPriceFormat(product),myExecutor))
                //將獲取的字符串解析成對(duì)象
                .map(future -> future.thenApply(Quote::parse))
                //使用另一個(gè)異步任務(wù)有獲取折扣價(jià)格
                .map(future -> future.thenCompose(quote -> CompletableFuture.supplyAsync(() -> Discount.applyDiscount(quote),myExecutor)));
        //thenAccept()會(huì)在CompletableFuture完成之后使用他的返回值，這里會(huì)持續(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對(duì)象構(gòu)成的數(shù)組，這里使用其等待所有的子線程執(zhí)行完畢
        CompletableFuture.allOf(futures).join();
    }

  

    /**
     * 異步查詢
     * 相比并行流的話CompletableFuture更有優(yōu)勢(shì)：可以對(duì)執(zhí)行器配置，設(shè)置線程池大小
     */
    @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);
            //使用守護(hù)線程保證不會(huì)阻止程序的關(guān)停
            t.setDaemon(true);
            return t;
        }
    });
   

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

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

anyOf():廠方法接受由CompletableFuture對(duì)象構(gòu)成的數(shù)組,返回?cái)?shù)組中第一個(gè)完成的CompletableFuture的返回值CompletableFuture