Java多線程基礎（十一）——Future模式

tinyq 發布于2019-08-16 12:40 / 3380人閱讀

摘要：一定義模式用來獲取線程的執行結果。案例中的類就是參與者參與者接受請求，然后創建線程進行異步處理。參與者會立即返回以的形式。虛擬數據參與者是用來統一代表參與者與參與者。

一、定義

Future模式用來獲取線程的執行結果。在Thread-Per-Message模式中，如果調用一個線程異步執行任務，沒有辦法獲取到返回值，就像：
host.request(10,"A");
而Future模式送出請求后，馬上就要獲取返回值，就像：
Data data=host.request(10,"A");
但是上述的返回值并不是程序的執行結果，因為線程是異步的，主線程調用該該方法時，異步線程可能才剛剛啟動。需要一段時間后像下面這樣獲取執行結果：
data.getContent();

二、模式案例

Data接口/實現：

public interface Data {
    public abstract String getContent();
}

public class RealData implements Data {
    private final String content;
    public RealData(int count, char c) {
        System.out.println("        making RealData(" + count + ", " + c + ") BEGIN");
        char[] buffer = new char[count];
        for (int i = 0; i < count; i++) {
            buffer[i] = c;
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
            }
        }
        System.out.println("        making RealData(" + count + ", " + c + ") END");
        this.content = new String(buffer);
    }
    public String getContent() {
        return content;
    }
}

public class FutureData implements Data {
    private RealData realdata = null;
    private boolean ready = false;
    public synchronized void setRealData(RealData realdata) {
        if (ready) {
            return;
        }
        this.realdata = realdata;
        this.ready = true;
        notifyAll();
    }
    public synchronized String getContent() {
        while (!ready) {
            try {
                wait();
            } catch (InterruptedException e) {
            }
        }
        return realdata.getContent();
    }
}

Host類：

public class Host {
    public Data request(final int count, final char c) {
        System.out.println("    request(" + count + ", " + c + ") BEGIN");
        final FutureData future = new FutureData();
        new Thread() {
            public void run() {
                RealData realdata = new RealData(count, c);
                future.setRealData(realdata);
            }
        }.start();
        System.out.println("    request(" + count + ", " + c + ") END");
        return future;
    }
}

執行：

public class Main {
    public static void main(String[] args) {
        System.out.println("main BEGIN");
        Host host = new Host();
        Data data1 = host.request(10, "A");
        Data data2 = host.request(20, "B");
        Data data3 = host.request(30, "C");
?
        System.out.println("main otherJob BEGIN");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
        }
        System.out.println("main otherJob END");
        System.out.println("data1 = " + data1.getContent());
        System.out.println("data2 = " + data2.getContent());
        System.out.println("data3 = " + data3.getContent());
        System.out.println("main END");
    }
}

三、模式講解

Future模式的角色如下：

Client（委托人）參與者

Client參與者會向Host參與者送出請求（request），Client參與者會馬上得到VirtualData，作為請求結果的返回值。（案例中的Main類就是Client）

Host參與者

Host參與者接受請求（request），然后創建線程進行異步處理。Host參與者會立即返回Future（以VirturalData的形式）。

VirtualData（虛擬數據）參與者

VirtualData是用來統一代表Future參與者與RealData參與者。（案例中Data接口就是VirtualData參與者）

RealData（實際數據）參與者

RealData表示實際的數據。

Future參與者

Future參與者包含獲取實際的數據和設置實際數據的方法。Host類會創建該對象，當異步線程處理完成時，會調用Future的設置數據的方法。

GPU云服務器云服務器 java線程池設計模式 java多線程多線程調試 java java多線程分發

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/71509.html

《java 8 實戰》讀書筆記 -第十一章 CompletableFuture：組合式異步編程

摘要：方法接受一個生產者作為參數，返回一個對象，該對象完成異步執行后會讀取調用生產者方法的返回值。該方法接收一個對象構成的數組，返回由第一個執行完畢的對象的返回值構成的。一、Future 接口在Future中觸發那些潛在耗時的操作把調用線程解放出來，讓它能繼續執行其他有價值的工作，不再需要呆呆等待耗時的操作完成。打個比方，你可以把它想象成這樣的場景：你拿了一袋子衣服到你中意的干洗店去洗。...

zhangqh 2019-08-16 17:05 評論0 收藏0
Flutter 面試知識點集錦

摘要：中的的線程是以事件循環和消息隊列的形式存在，包含兩個任務隊列，一個是內部隊列，一個是外部隊列，而的優先級又高于。同時還有處理按住時的事件額外處理，同時手勢處理一般在的子類進行。谷歌大會之后，有不少人咨詢了我 Flutter 相關的問題，其中有不少是和面試相關的，如今一些招聘上也開始羅列 Flutter 相關要求，最后想了想還是寫一期總結吧，也算是 Flutter 的階段復習。 ??系統完...

andong777 2019-05-21 19:52 評論0 收藏0
《Java8實戰》-第十一章筆記（CompletableFuture：組合式異步編程）

摘要：組合式異步編程最近這些年，兩種趨勢不斷地推動我們反思我們設計軟件的方式。第章中介紹的分支合并框架以及并行流是實現并行處理的寶貴工具它們將一個操作切分為多個子操作，在多個不同的核甚至是機器上并行地執行這些子操作。 CompletableFuture：組合式異步編程最近這些年，兩種趨勢不斷地推動我們反思我們設計軟件的方式。第一種趨勢和應用運行的硬件平臺相關，第二種趨勢與應用程序的架構相關...

hlcfan 2019-08-16 13:40 評論0 收藏0
Java SDK 并發包全面總結

摘要：一和并發包中的和主要解決的是線程的互斥和同步問題，這兩者的配合使用，相當于的使用。寫鎖與讀鎖之間互斥，一個線程在寫時，不允許讀操作。的注意事項不支持重入，即不可反復獲取同一把鎖。沒有返回值，也就是說無法獲取執行結果。一、Lock 和 Condition Java 并發包中的 Lock 和 Condition 主要解決的是線程的互斥和同步問題，這兩者的配合使用，相當于 synchron...

luckyyulin 2019-08-16 17:44 評論0 收藏0
Java多線程進階（四二）—— J.U.C之executors框架：Future模式

摘要：本文首發于一世流云的專欄一模式簡介模式是多線程設計模式中的一種常見模式，它的主要作用就是異步地執行任務，并在需要的時候獲取結果。二中的模式在多線程基礎之模式中，我們曾經給出過模式的通用類關系圖。 showImg(https://segmentfault.com/img/bVbiwcx?w=1000&h=667); 本文首發于一世流云的專欄：https://segmentfault.co...

marek 2019-08-16 13:29 評論0 收藏0