摘要：本人郵箱歡迎轉載轉載請注明網址代碼已經全部托管有需要的同學自行下載引言前面我們講了那么多有關線程的知識不知道讀者有沒有想過這么一個問題如果有這么一個比較耗時的任務必須使用線程來執行但是在這個任務執行完之后我需要得到這個線程的返回值以目前我們

本人郵箱: 
歡迎轉載,轉載請注明網址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經全部托管github有需要的同學自行下載

前面我們講了那么多有關線程的知識.不知道讀者有沒有想過這么一個問題,如果有這么一個比較耗時的任務,必須使用線程來執行,但是在這個任務執行完之后,我需要得到這個線程的返回值.以目前我們學到的知識,具體實現,我這里不說,大家自行發揮.除此之外,如果線程發生了非運行時異常,我們在主線程就會收到一堆錯誤信息.還有我們也無法判斷任務是否執行完成,有些人會說用Thread1.isAlive()就可以判斷任務是否執行完成.這是錯的,因為isAlive只是判斷線程是否存活,而無法判斷任務是否完成,兩者是不一樣的概念.如果有沒有不明白的,請考慮使用線程池ThreadPoolExecutor的情況.
以上說了那么多,其實就是為了引入今天要講的Callable,Future,FutureTask.ok,讓我們看一下這些類是干什么的.

*Callable 可以說是 Runnable的升級版本,既有拋出錯誤也有返回類型.
*Future 是執行異步任務后的返回值,這個接口包括一下幾個方法

* `cancel(boolean mayInterruptIfRunning)` 取消任務,如果`mayInterruptIfRunning`為`true`,即使該任務在運行也可以被中斷.否則在運行中的任務不能被取消.
* `isCancelled`判斷任務是否被取消
* `isDone` 判斷任務是否完成
* `get` 獲取任務的返回值,如果任務有異常,則在調用這個方法的時候被拋出
* `get(long timeout, TimeUnit unit)` 在指定時間內等待獲取任務的返回值,如果任務有異常,則在調用這個方法的時候被拋出

FutureTask 是Runnable和Future的子類

public class Demo1 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("main start");
        FutureTask task = new FutureTask(() -> System.out.println("執行子任務"), "hello");
        new Thread(task).start();
        while (task.isDone());
        System.out.println("任務返回結果:" + task.get());
        System.out.println("main end");
    }
}

運行結果

main start
執行子任務
任務返回結果:hello
main end

public FutureTask(Runnable runnable, V result) 這個比較適合固定任務返回固定值的情況,如果返回的值需要進過計算,所以有多個情況,則不適合使用這個構造.

public class Demo2 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("main start");
        FutureTask task = new FutureTask(() -> {
            int sum = 0;
            for (int i = 1; i <= 100; i++){
                sum += i;
            }
            return sum;
        });
        new Thread(task).start();
        while (task.isDone());
        System.out.println("任務返回結果:" + task.get());
        System.out.println("main end");
    }
}

返回結果

main start
任務返回結果:5050
main end

public class Demo3 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("main start");
        FutureTask task = new FutureTask(() -> {
            System.out.println("正在執行子任務");
            int i = 1 / 0;
            return 0;
        });
        new Thread(task).start();
        while (task.isDone());
        System.out.println("任務返回結果:" + task.get());
        System.out.println("main end");
    }
}

運行結果:

main start
正在執行子任務
Exception in thread "main" java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
  at java.util.concurrent.FutureTask.report(FutureTask.java:122)
  at java.util.concurrent.FutureTask.get(FutureTask.java:192)
  at com.kco.test18.demo.Demo3.main(Demo3.java:19)
  at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  at java.lang.reflect.Method.invoke(Method.java:497)
  at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)
Caused by: java.lang.ArithmeticException: / by zero
  at com.kco.test18.demo.Demo3.lambda$main$0(Demo3.java:14)
  at com.kco.test18.demo.Demo3$$Lambda$1/27095111.call(Unknown Source)
  at java.util.concurrent.FutureTask.run(FutureTask.java:266)
  at java.lang.Thread.run(Thread.java:745)

需要注意的是,這是拋出的異常是在調用task.get()才拋出的,如果把task.get()注釋掉,是不會拋出異常的.所以我們就可以對異常做一下自定義處理.比如寫到日志中.

public class Demo4 {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        System.out.println("main start");
        FutureTask task = new FutureTask(() -> {
            System.out.println("start 正在執行子任務");
            Thread.sleep(500);
            System.out.println("end 執行子任務");
            return 0;
        });
        new Thread(task).start();
        Thread.sleep(250);
        task.cancel(true);
        System.out.println("main end");
    }
}

運行結果

main start
start 正在執行子任務
main end

發現子任務確實運行運行了一般,然后被取消了.

上一篇講到了ThreadPoolExecutor,我們在執行任務的時候只使用了execute,這個是沒有返回值的.而且如果任務拋出異常,則會直接在主線程打印出錯誤堆棧的.其實ThreadPoolExecutor還有另外一個提交任務的方法,就是submit(Runnable task, T result)和submit(Callable task),使用的就是我們這章節所講的內容.大家可以自行寫例子測試這兩個方法.

如果覺得我的文章寫的還過得去的話,有錢就捧個錢場,沒錢給我捧個人場(幫我點贊或推薦一下)