解析Java語(yǔ)言中如何使用Future類的方法

public interface Data {
    public String getResult ();
}

public class FutureData implements Data {
    // 內(nèi)部需要維護(hù)RealData
    protected RealData realdata = null;          
    protected boolean isReady = false;
    public synchronized void setRealData(RealData realdata) {
        if (isReady) { 
            return;
        }
        this.realdata = realdata;
        isReady = true;
        //RealData已經(jīng)被注入，通知getResult()
        notifyAll();                            			
    }
    //會(huì)等待RealData構(gòu)造完成
    public synchronized String getResult() {        	
        while (!isReady) {
            try {
                //一直等待，直到RealData被注入
                wait();                        			
            } catch (InterruptedException e) {
            }
        }
        //真正需要的數(shù)據(jù)從RealData獲取
        return realdata.result;                    		
    }
}

public class Client {
    //這是一個(gè)異步方法，返回的Data接口是一個(gè)Future
    public Data request(final String queryStr) {
        final FutureData future = new FutureData();
        new Thread() {                                      
            public void run() {                    	
                // RealData的構(gòu)建很慢，所以在單獨(dú)的線程中進(jìn)行
                RealData realdata = new RealData(queryStr);
                //setRealData()的時(shí)候會(huì)notify()等待在這個(gè)future上的對(duì)象
                future.setRealData(realdata);
            }                                               
        }.start();
        // FutureData會(huì)被立即返回，不會(huì)等待RealData被構(gòu)造完
        return future;                        		
    }
}

public static void main(String[] args) {
    Client client = new Client();
    //這里會(huì)立即返回，因?yàn)榈玫降氖荈utureData而不是RealData
    Data data = client.request("name");
    System.out.println("請(qǐng)求完畢");
    try {
        //這里可以用一個(gè)sleep代替了對(duì)其他業(yè)務(wù)邏輯的處理
        //在處理這些業(yè)務(wù)邏輯的過(guò)程中，RealData被創(chuàng)建，從而充分利用了等待時(shí)間
        Thread.sleep(2000);
    } catch (InterruptedException e) {
    }
    //使用真實(shí)的數(shù)據(jù)，如果到這里數(shù)據(jù)還沒(méi)有準(zhǔn)備好，getResult()會(huì)等待數(shù)據(jù)準(zhǔn)備完，再返回
    System.out.println("數(shù)據(jù) = " + data.getResult());
}

        //異步操作 可以用一個(gè)線程池
        ExecutorService executor = Executors.newFixedThreadPool(1);
        //執(zhí)行FutureTask，相當(dāng)于上例中的 client.request("name") 發(fā)送請(qǐng)求
        //在這里開(kāi)啟線程進(jìn)行RealData的call()執(zhí)行
        Future<String> future = executor.submit(new RealData("name"));
        System.out.println("請(qǐng)求完畢，數(shù)據(jù)準(zhǔn)備中");
        try {
            //這里依然可以做額外的數(shù)據(jù)操作，這里使用sleep代替其他業(yè)務(wù)邏輯的處理
            Thread.sleep(2000);
        } catch (InterruptedException e) {
        }
        //如果此時(shí)call()方法沒(méi)有執(zhí)行完成，則依然會(huì)等待
        System.out.println("數(shù)據(jù) = " + future.get());

    public <T> Future<T> submit(Callable<T> task) {
        if (task == null) throw new NullPointerException();
        // 根據(jù)Callable對(duì)象，創(chuàng)建一個(gè)RunnableFuture，這里其實(shí)就是FutureTask
        RunnableFuture<T> ftask = newTaskFor(task);
        //將ftask推送到線程池
        //在新線程中執(zhí)行的，就是run()方法，在下面的代碼中有給出
        execute(ftask);
        //返回這個(gè)Future，將來(lái)通過(guò)這個(gè)Future就可以得到執(zhí)行的結(jié)果
        return ftask;
    }
    protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
        return new FutureTask<T>(callable);
    }

    public V get() throws InterruptedException, ExecutionException {
        int s = state;
        //如果沒(méi)有完成，就等待，回到用park()方法阻塞線程
        //同時(shí)，所有等待線程會(huì)在FutureTask的waiters字段中排隊(duì)等待
        if (s <= COMPLETING)
            s = awaitDone(false, 0L);
        return report(s);
    }
    private V report(int s) throws ExecutionException {
        //outcome里保存的就是最終的計(jì)算結(jié)果
        Object x = outcome;
        if (s == NORMAL)
            //正常完成，就返回outcome
            return (V)x;
        //如果沒(méi)有正常完成， 比如被用戶取消了，或者有異常了，就拋出異常
        if (s >= CANCELLED)
            throw new CancellationException();
        throw new ExecutionException((Throwable)x);
    }

        public void run() {
            CompletableFuture<T> d; Supplier<T> f;
            if ((d = dep) != null && (f = fn) != null) {
                dep = null; fn = null;
                if (d.result == null) {
                    try {
                        //這里就是你要執(zhí)行的異步方法
                        //結(jié)果會(huì)被保存下來(lái)，放到d.result字段中
                        d.completeValue(f.get());
                    } catch (Throwable ex) {
                        d.completeThrowable(ex);
                    }
                }
                //執(zhí)行成功了，進(jìn)行后續(xù)處理，在這個(gè)后續(xù)處理中，就會(huì)調(diào)用thenAccept()中的消費(fèi)者
                //這里就相當(dāng)于Future完成后的通知
                d.postComplete();
            }
        }

   final void postComplete() {
                //省略部分代碼，重點(diǎn)在tryFire()里
                //在tryFire()里，真正觸發(fā)了后續(xù)的調(diào)用，也就是thenAccept()中的部分
                f = (d = h.tryFire(NESTED)) == null ? this : d;
            }
        }
    }