Callable、Future、RunnableFuture、FutureTask的原理及應用

来源:http://www.cnblogs.com/nullzx/archive/2016/01/21/5147004.html
-Advertisement-
Play Games

1. Callable、Future、RunnableFuture、FutureTask的繼承關係 在多線程編程中，我們一般通過一個實現了Runnable介面的對象來創建一個線程，這個線程在內部會執行Runnable對象的run方法。如果說我們創建一個線程來完成某項工作，希望在完成以後該線程能夠返回...


1. Callable、Future、RunnableFuture、FutureTask的繼承關係

clip_image002

        在多線程編程中，我們一般通過一個實現了Runnable介面的對象來創建一個線程，這個線程在內部會執行Runnable對象的run方法。如果說我們創建一個線程來完成某項工作，希望在完成以後該線程能夠返回一個結果，但run方法的返回值是void類型，直接實現run方法並不可行，這時我們就要通過FutureTask類來間接實現。

        FutureTask實現了RunnableFuture介面，而RunnableFuture介面實際上僅僅是Runnable介面和Future介面的合體。Future介面提供取消任務、檢測任務是否執行完成、等待任務執行完成獲得結果等方法。從圖中可以看出，FutureTask類中的run方法已經實現好了（圖中的代碼僅僅是核心代碼），這個run方法實際上就是調用了由構造函數傳遞進來的call方法，並將返回值存儲在FutureTask的私有數據成員outcome中。這樣一來我們將FutureTask傳遞給一個Thread時，錶面上我們仍然執行的是run，但在run方法的內部實際上執行的是帶有返回值的call方法，這樣即使得java多線程的執行框架保持不變，又實現了線程完成後返回結果的功能。同時FutureTask又將結果存儲在outcome中，我們可以通過調用FutureTask對象的get方法獲取outcome（也就是call方法的返回結果）。

Future介面功能介紹

boolean cancel(boolean mayInterruptIfRunning);

功能：設置線程的中斷標誌位

參數：mayInterruptIfRunning為ture，如果線程可以取消則設置線程的中斷標誌位

返回值：若線程已經完成，返回false;否則返回true

註意：要實現取消線程執行的功能，call函數需要在迴圈條件中檢查中斷標誌位，以跳出迴圈

boolean isCancelled();

判斷線程是否取消

boolean isDone();

線程執行完成，返回true；如果cancel方法返回true，則該方法也返回true

V get() throws InterruptedException, ExecutionException;

獲取call方法的返回結果，如果call方法沒有執行完成，則會阻塞當前線程，直到call方法執行完畢，才被喚醒

V get(long timeout, TimeUnit unit)

設置時限的get方法。

2. Future及FutureTask的使用

      Future以及FutureTask是線程池實現的基礎元素，但不是說Future及FutureTask只能線上程池中才能使用，下麵的例子就說明瞭FutureTask獨立使用的情況。在這個例子中，我們首先隨機產生了2000個整數存於數組中，然後創建了兩個線程，一個線程尋找前1000個數的最大值，另個一線程尋找後1000個數的最大值。主線程比較這兩個線程的返回結果來確定這2000個數的最大值值。

package javaleanning;

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class FutureDemo {
	public static void main(String[] args) throws InterruptedException, ExecutionException{
		int[] a = new int[2000];
		Random rd = new Random();
		for(int i = 0; i < 2000; i++){
			a[i] = rd.nextInt(20000);
		}
		
		class FindMax implements Callable<Integer>{
			private int begin,end,int a[];
			public FindMax(int a[],int begin, int end){
				this.a = a;
                                this.begin = begin;
				this.end = end;
			}
			@Override
			public Integer call() throws Exception {
				int maxInPart = a[begin];
				for(int i = begin; i <= end; i++){
					if(a[i] > maxInPart){
						maxInPart = a[i];
					}
				}
				return new Integer(maxInPart);
			}
		}
		
		FutureTask<Integer> findMaxInFirstPart = 
                              new FutureTask<Integer>(new FindMax(a,0,999));
		FutureTask<Integer> findMaxInSecondPart = 
                              new FutureTask<Integer>(new FindMax(a,1000,1999));
		
		new Thread(findMaxInFirstPart).start();
		new Thread(findMaxInSecondPart).start();
		
		int maxInFirst =  (int) findMaxInFirstPart.get();
		int maxInSecond = (int) findMaxInSecondPart.get();
		System.out.println("Max is " + 
                            (maxInFirst > maxInSecond ? maxInFirst:maxInSecond));
		//驗證結果是否正確
		int max = a[0];
		for(int i = 0; i < 2000; i++){
			if(a[i] > max){
				max = a[i];
			}
		}
		System.out.println(max);
	}
}

3. FutureTask的實現原理

構造函數 

public FutureTask(Callable<V> callable) {
    if (callable == null)
        throw new NullPointerException();
    this.callable = callable;
    this.state = NEW;       // ensure visibility of callable
}

public FutureTask(Runnable runnable, V result) {
    this.callable = Executors.callable(runnable, result);
    this.state = NEW;       // ensure visibility of callable
}

     FutureTask有兩個構造函數，通常來說我們使用第一個構造函數。這裡要強調一下第二個構造函數，它有兩個類型參數，分別是Runnable類型和泛型V，然後由這兩個構造一個Callable對象。當線程運行結束以後會返回由構造函數傳遞進來的這個泛型result對象，也就是說返回的值並不是通過運行得到的，而是由構造函數獲取的一個指定的對象。

重要數據成員 

private volatile int state;
private Object outcome; 
private volatile Thread runner;
private volatile WaitNode waiters;

         state表明瞭線程運行call方法的狀態，初始狀態為0，完成後由run方法將其設置為1。通過get方法獲取結果時就必須檢查state的值，如果該值為0，表明需要等待該結果，get方法就會將當前線程阻塞。

        outcome表示了call方法的返回結果

        runner表示運行FutureTask方法的線程，其值會在run方法中進行初始化

        waiters指向了因獲取結果而等待的線程組成的隊列

重要方法 

public void run() {
    if (state != NEW ||
        !UNSAFE.compareAndSwapObject(this, runnerOffset,
                                     null, Thread.currentThread()))
        return;
    try {
        Callable<V> c = callable;
        if (c != null && state == NEW) {
            V result;
            boolean ran;
            try {
                result = c.call();
                ran = true;
            } catch (Throwable ex) {
                result = null;
                ran = false;
                setException(ex);
            }
            if (ran)
                set(result);
        }
    } finally {
        // runner must be non-null until state is settled to
        // prevent concurrent calls to run()
        runner = null;
        // state must be re-read after nulling runner to prevent
        // leaked interrupts
        int s = state;
        if (s >= INTERRUPTING)
            handlePossibleCancellationInterrupt(s);
    }
}

         從代碼中可以看出run方法中調用了從構造函數傳遞來的call方法。 

protected void set(V v) {
    if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
        outcome = v;
        UNSAFE.putOrderedInt(this, stateOffset, NORMAL); // final state
        finishCompletion();
    }
}

       當call方法執行完畢後，run方法調用又調用了set方法，它主要實現兩個功能，一個是將結果賦值給outcome，另一個是通過finishCompletion喚醒由調用此FutureTask對象的get方法而阻塞的線程 

private void finishCompletion() {
    // assert state > COMPLETING;
    for (WaitNode q; (q = waiters) != null;) {
        if (UNSAFE.compareAndSwapObject(this, waitersOffset, q, null)) {
            for (;;) {
                Thread t = q.thread;
                if (t != null) {
                    q.thread = null;
                    LockSupport.unpark(t);
                }
                WaitNode next = q.next;
                if (next == null)
                    break;
                q.next = null; // unlink to help gc
                q = next;
            }
            break;
        }
    }

    done();

    callable = null;        // to reduce footprint
}

  

public V get() throws InterruptedException, ExecutionException {
    int s = state;
    if (s <= COMPLETING)
        s = awaitDone(false, 0L);
    return report(s);
}

        在get方法中首先判斷了state的值，如果call方法還未完成，就會通過awaitDone來阻塞自己。

private int awaitDone(boolean timed, long nanos)
        throws InterruptedException {
        final long deadline = timed ? System.nanoTime() + nanos : 0L;
        WaitNode q = null;
        boolean queued = false;
        for (;;) {
            if (Thread.interrupted()) {
                removeWaiter(q);
                throw new InterruptedException();
            }

            int s = state;
            if (s > COMPLETING) {
                if (q != null)
                    q.thread = null;
                return s;
            }
            else if (s == COMPLETING) // cannot time out yet
                Thread.yield();
            else if (q == null)
                q = new WaitNode();
            else if (!queued)
                queued = UNSAFE.compareAndSwapObject(this, waitersOffset,
                                                     q.next = waiters, q);
            else if (timed) {
                nanos = deadline - System.nanoTime();
                if (nanos <= 0L) {
                    removeWaiter(q);
                    return state;
                }
                LockSupport.parkNanos(this, nanos);
            }
            else
                LockSupport.park(this);
        }
    }

public boolean cancel(boolean mayInterruptIfRunning) {
    if (!(state == NEW &&
          UNSAFE.compareAndSwapInt(this, stateOffset, NEW,
              mayInterruptIfRunning ? INTERRUPTING : CANCELLED)))
        return false;
    try {    // in case call to interrupt throws exception
        if (mayInterruptIfRunning) {
            try {
                Thread t = runner;
                if (t != null)
                    t.interrupt();
            } finally { // final state
                UNSAFE.putOrderedInt(this, stateOffset, INTERRUPTED);
            }
        }
    } finally {
        finishCompletion();
    }
    return true;
}

       在cannel方法中，如果允許對線程中斷，則設置該線程的中斷標誌位，並通過finishCompletion方法喚醒因等待結果而阻塞的線程。

參考文章

[1] http://www.cnblogs.com/dolphin0520/p/3949310.html

[2] http://www.open-open.com/lib/view/open1384351141649.html

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • python中if __name__ == '__main__': 的解析
    當你打開一個.py文件時,經常會在代碼的最下麵看到if __name__ == '__main__':,現在就來介 紹一下它的作用. 模塊是對象，並且所有的模塊都有一個內置屬性 __name__。一個模塊的 __name__ 的值取決於您如何應用模塊。如果 import 一個模塊，那麼模塊__nam...
  • iOS開發--Swift 基於AFNetworking 3.0的網路請求封裝
    Swift和OC基於AFNetworking的網路請求流程相同, 就是語法不同, 對於Swift語法不是很清楚的同學, 建議多看看API文檔, 自己多多嘗試. 寫過OC的應該都明白每句話做什麼的, 就不過多解釋了. 之前有講過如何進行混編, 所以集成AFNetworking的過程就不再贅述 ...
  • eclipse中java項目的build path詳解
    BuildPath中只支持加入jar文件，具體方法如下：在eclips里在工程名上右鍵->build path->contigure bud path->java build path里有個libraries->add external jars = 增加工程外部的包add jars = 增加工程內...
  • Django安裝和啟動
    1.django安裝在http://www.djangoproject.com/download/這個網站上可以下載django的最新版本。在下載時，要註意django版本和本機安裝的Python版本是匹配的。在這個https://docs.djangoproject.com/en/dev/faq/...
  • smarty安裝及例子
    環境：smarty1.在http://www.smarty.net/download下載最新smarty包，window選擇zips，linux下選擇tar.gz。以windows為例，下載後解壓，如f:\smarty。2.把解壓出來的smarty目錄里lib目錄拷貝到test里，重命名為smart...
  • 真正明白C語言二級指針
    指針是C語言的靈魂，我想對於一級指針大家應該都很熟悉，也經常用到：比如說對於字元串的處理，函數參數的“值，結果傳遞”等，對於二級指針或者多級指針，我想理解起來也是比較容易的，比如二級指針就是指向指針的指針.....n級指針就是....但是可能大家比較不容易理解的是，二級指針或者多級指針用在哪裡呢？怎...
  • List的遍歷和刪除元素
    /** * 遍歷list的方法 * @param args */ public static void main(String[] args) { List list = new ArrayList(); list.add("111"); ...
  • OC中用指針修改對象屬性容易進的誤區,看你中過槍沒有
    對於初學者朋友,在OC指針指針修改對象屬性掌握起來一般問題不大的,但是要再來幾個"函數"和你"折騰"呢?哈哈!看看你又沒有中過槍吧!看下麵一段代碼:void test1(int newAge,double newHeight);void test2(Person *newP);void tes...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類