概述：

image.png

說到多線程的future,百度 多線程 future,網(wǎng)上也有各式各樣的例子,寫的比我還要好,但是實(shí)在是這個(gè)模式或者說例子以及實(shí)用性太大了,我不得不拿出來講,甚至在實(shí)際生產(chǎn)環(huán)境中也是可以用的.我呢,也是拿出網(wǎng)上的例子詳細(xì)的講一遍~~

看下面的圖↓↓↓↓↓

image.png

如上圖,傳統(tǒng)的訂單下單流程,首先減商品庫存,然后生成訂單,然后生成訂單詳情,再通知短信等等,全部邏輯程序都是串行執(zhí)行的.假如我們的系統(tǒng)特別'困難',減商品庫存要1秒,生成訂單要1秒,生成詳情也要1秒,發(fā)送短信有可能要5秒,這里還不算查詢商品的庫存夠不夠下單等等,那么一系列的操作就要花很多時(shí)間.

那么引入多線程的future有什么好處呢?看下圖↓↓↓↓↓↓↓

image.png

看這圖很簡單,用戶下單,future對(duì)象直接告訴你下單成功,返回給你一個(gè)假數(shù)據(jù),同時(shí)自己偷偷的新建了一個(gè)或者幾個(gè)線程處理其他業(yè)務(wù)邏輯,等邏輯處理完了,再返回一個(gè)正確的結(jié)果.

然后是上代碼~~

public interface Data {
    String getRequest();
}

public class RealData implements Data {
    private String result;

    public RealData(String request) {
        System.out.println("根據(jù)" + request + "進(jìn)行查詢..,要花很久時(shí)間");
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("操作完畢,獲取結(jié)果");
        result = "查詢結(jié)果";
    }

    public String getRequest() {
        return result;
    }
}

public class FutureData implements Data {

    private RealData realData;

    private boolean isReady = false;

    public synchronized String getRequest() {

        while (!isReady) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        return this.realData.getRequest();
    }

    public synchronized void setRealData(RealData realData) {
        if (isReady) {
            return;
        }
        this.realData = realData;
        isReady = true;
        notify();
    }
}

public class FutureClient {
    public Data request(final String request) {
        final FutureData futureData = new FutureData();

        new Thread(new Runnable() {

            public void run() {
                RealData realData = new RealData(request);
                futureData.setRealData(realData);
            }
        }).start();

        return futureData;
    }
}

public class Main {

    public static void main(String[] args) {
        FutureClient fClient = new FutureClient();

        Data data = fClient.request("hello,world");

        System.out.println("請(qǐng)求發(fā)送成功...");
        System.out.println("干其他的事情...");

        String result = data.getRequest();

        System.out.println(result);
    }
}

一共5個(gè)類,剛開始看會(huì)有點(diǎn)懵逼,正常,我也是懵逼的,我到現(xiàn)在也還是懂了90%,為什么懂90%就敢講,其實(shí)也差不多了~自己按照代碼一個(gè)單詞一個(gè)單詞的教,自然就懂思想.就按照我貼的代碼順序我們一點(diǎn)一點(diǎn)看,這個(gè)模式很有意思的,真的能學(xué)到很多東西.

首先看這個(gè)接口Data,只有一個(gè)方法getRequest(),返回String字符串.

然后再看RealData這個(gè)類,實(shí)現(xiàn)了Data接口,首先他有構(gòu)造函數(shù),打印了兩句話,然后中間sleep一下,做這個(gè)sleep我們可以想象成在處理業(yè)務(wù)邏輯.

接著再看FutureData這個(gè)類,也實(shí)現(xiàn)了Data接口.先看FutureData的getRequest()方法,這個(gè)方法先死循環(huán)判斷boolean,如果isReady是true,就阻塞著,不然就返回RealData真的getRequest()方法(真實(shí)的結(jié)果).然后再看setRealData(),判斷isReady,如果是ture,直接return,如果不是就賦值RealData,并修改isReady,然后notify()..

其實(shí)很好理解,不要看到synchronized,notify,wait就暈了,FutureData這個(gè)類干了啥,你想,wait什么?不就是等notify嗎,如果沒有notify,那我就得等著,等什么?還是等通知啊,只有通知了,那么我才能進(jìn)行下去,進(jìn)行下去什么?--->RealData.getRequset()啊,就是真實(shí)的數(shù)據(jù),為什么要等?因?yàn)檫€在處理啊,只有真實(shí)的數(shù)據(jù)處理完了,然后通知,也就是說FutureData這個(gè)類的setRealData()只是起到通知的作用,再看setRealData()傳入的是RealData對(duì)象,RealData干了啥事,不就是有個(gè)構(gòu)造函數(shù)實(shí)現(xiàn)自己的業(yè)務(wù)嗎,實(shí)現(xiàn)完了就可以通知!!還不懂,自己敲代碼..結(jié)合我說的多讀幾遍,別被饒暈了~~~

最后看FutureClient 這個(gè)類,最簡單了,返回futureData,偷偷開了線程,看到RealData realData = new RealData(request)沒有?就是開始執(zhí)行業(yè)務(wù)了,然后當(dāng)FutureData這個(gè)類的setRealData(RealData realData)時(shí)就通知了..我現(xiàn)在都100%懂了~~~~~~~

最后Main方法就不說了~

打印結(jié)果↓↓↓↓↓↓

請(qǐng)求發(fā)送成功...
干其他的事情...
根據(jù)hello,world進(jìn)行查詢..,要花很久時(shí)間
操作完畢,獲取結(jié)果
查詢結(jié)果

第四句話和第五話是2秒后才出來的~~~~

上面的原理你可以不用懂,當(dāng)然懂最好了,可以在面試官面前吹牛逼啊..future模式這么兇殘,jdk也有實(shí)現(xiàn)的,在java.util.concurrent,又是concurrent,這個(gè)工具類真的是強(qiáng)大_{上代碼,就不說了}~

import java.util.concurrent.Callable;

public class RealData implements Callable<String> {
    private String Data;

    public RealData(String Data) {
        this.Data = Data;
    }

    public String call() throws Exception {
        //利用sleep來表示任務(wù)處理
        Thread.sleep(2000);

        return "這是處理"+Data+"結(jié)果";
    }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

public class Main {

    public static void main(String[] args) throws Exception {
        Long start = System.currentTimeMillis();

        FutureTask<String> futureTask = new FutureTask<>(new RealData("hello,world"));
        ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(1);
        newFixedThreadPool.submit(futureTask);

        // 表示正在處理其他邏輯,或者業(yè)務(wù)
        Thread.sleep(1000);

        System.out.println("最后結(jié)果-->" + futureTask.get());

        Long end = System.currentTimeMillis();

        Long useTime = end - start;

        System.out.println("程序運(yùn)行了-->" + useTime + "毫秒");
    }

}

最后奉上打印結(jié)果↓↓↓↓↓

最后結(jié)果-->這是處理hello,world結(jié)果
程序運(yùn)行了-->2004毫秒

看2秒就執(zhí)行完了..最好自己敲一遍~~~~~