Java帶有返回結果的新執行緒:Callable
Java併發程式設計:Callable、Future和FutureTask
在前面的文章中我們講述了建立執行緒的2種方式,一種是直接繼承Thread,另外一種就是實現Runnable介面。
這2種方式都有一個缺陷就是:在執行完任務之後無法獲取執行結果。
如果需要獲取執行結果,就必須通過共享變數或者使用執行緒通訊的方式來達到效果,這樣使用起來就比較麻煩。
而自從Java 1.5開始,就提供了Callable和Future,通過它們可以在任務執行完畢之後得到任務執行結果。
今天我們就來討論一下Callable、Future和FutureTask三個類的使用方法。以下是本文的目錄大綱:
一.Callable與Runnable
二.Future
三.FutureTask
四.使用示例
若有不正之處請多多諒解,並歡迎批評指正。
請尊重作者勞動成果,轉載請標明原文連結:
http://www.cnblogs.com/dolphin0520/p/3949310.html
一.Callable與Runnable
先說一下java.lang.Runnable吧,它是一個介面,在它裡面只聲明瞭一個run()方法:
1 2 3 |
public interface Runnable
{ public abstract void run();
}
|
由於run()方法返回值為void型別,所以在執行完任務之後無法返回任何結果。
Callable位於java.util.concurrent包下,它也是一個介面,在它裡面也只聲明瞭一個方法,只不過這個方法叫做call():
1 2 3 4 5 6 7 8 9 |
public interface Callable<V>
{
/**
*
Computes a result, or throws an exception if unable to do so. *
*
@return computed result
*
@throws Exception if unable to compute a result
*/
V
call() throws Exception;
}
|
可以看到,這是一個泛型介面,call()函式返回的型別就是傳遞進來的V型別。
那麼怎麼使用Callable呢?一般情況下是配合ExecutorService來使用的,在ExecutorService介面中聲明瞭若干個submit方法的過載版本:
1 2 3 |
<T>
Future<T> submit(Callable<T> task);
<T>
Future<T> submit(Runnable task, T result);
Future<?>
submit(Runnable task);
|
第一個submit方法裡面的引數型別就是Callable。
暫時只需要知道Callable一般是和ExecutorService配合來使用的,具體的使用方法講在後面講述。
一般情況下我們使用第一個submit方法和第三個submit方法,第二個submit方法很少使用。
二.Future
Future就是對於具體的Runnable或者Callable任務的執行結果進行取消、查詢是否完成、獲取結果。必要時可以通過get方法獲取執行結果,該方法會阻塞直到任務返回結果。
Future類位於java.util.concurrent包下,它是一個介面:
1 2 3 4 5 6 7 8 |
public interface Future<V>
{
boolean cancel( boolean mayInterruptIfRunning);
boolean isCancelled();
boolean
|