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

　　

　　先說一下java.lang.Runnable吧，它是一個接口，在它裡面隻聲明了一個run()方法：

1

2

3

<code>public</code> <code>interface</code> <code>Runnable {</code>

<code>    </code><code>public</code> <code>abstract</code> <code>void</code> <code>run();</code>

<code>}</code>

 　　由于run()方法傳回值為void類型，是以在執行完任務之後無法傳回任何結果。

　　Callable位于java.util.concurrent包下，它也是一個接口，在它裡面也隻聲明了一個方法，隻不過這個方法叫做call()：

4

5

6

7

8

9

<code>public</code> <code>interface</code> <code>Callable&lt;V&gt; {</code>

<code>    </code><code>/**</code>

<code>     </code><code>* Computes a result, or throws an exception if unable to do so.</code>

<code>     </code><code>*</code>

<code>     </code><code>* @return computed result</code>

<code>     </code><code>* @throws Exception if unable to compute a result</code>

<code>     </code><code>*/</code>

<code>    </code><code>V call() </code><code>throws</code> <code>Exception;</code>

 　　可以看到，這是一個泛型接口，call()函數傳回的類型就是傳遞進來的V類型。

　　那麼怎麼使用Callable呢？一般情況下是配合ExecutorService來使用的，在ExecutorService接口中聲明了若幹個submit方法的重載版本：

<code>&lt;T&gt; Future&lt;T&gt; submit(Callable&lt;T&gt; task);</code>

<code>&lt;T&gt; Future&lt;T&gt; submit(Runnable task, T result);</code>

<code>Future&lt;?&gt; submit(Runnable task);</code>

　　第一個submit方法裡面的參數類型就是Callable。

　　暫時隻需要知道Callable一般是和ExecutorService配合來使用的，具體的使用方法講在後面講述。

　　一般情況下我們使用第一個submit方法和第三個submit方法，第二個submit方法很少使用。

　　Future就是對于具體的Runnable或者Callable任務的執行結果進行取消、查詢是否完成、擷取結果。必要時可以通過get方法擷取執行結果，該方法會阻塞直到任務傳回結果。

　　Future類位于java.util.concurrent包下，它是一個接口：

<code>public</code> <code>interface</code> <code>Future&lt;V&gt; {</code>

<code>    </code><code>boolean</code> <code>cancel(</code><code>boolean</code> <code>mayInterruptIfRunning);</code>

<code>    </code><code>boolean</code> <code>isCancelled();</code>

<code>    </code><code>boolean</code> <code>isDone();</code>

<code>    </code><code>V get() </code><code>throws</code> <code>InterruptedException, ExecutionException;</code>

<code>    </code><code>V get(</code><code>long</code> <code>timeout, TimeUnit unit)</code>

<code>        </code><code>throws</code> <code>InterruptedException, ExecutionException, TimeoutException;</code>

 　　在Future接口中聲明了5個方法，下面依次解釋每個方法的作用：

cancel方法用來取消任務，如果取消任務成功則傳回true，如果取消任務失敗則傳回false。參數mayInterruptIfRunning表示是否允許取消正在執行卻沒有執行完畢的任務，如果設定true，則表示可以取消正在執行過程中的任務。如果任務已經完成，則無論mayInterruptIfRunning為true還是false，此方法肯定傳回false，即如果取消已經完成的任務會傳回false；如果任務正在執行，若mayInterruptIfRunning設定為true，則傳回true，若mayInterruptIfRunning設定為false，則傳回false；如果任務還沒有執行，則無論mayInterruptIfRunning為true還是false，肯定傳回true。

isCancelled方法表示任務是否被取消成功，如果在任務正常完成前被取消成功，則傳回 true。

isDone方法表示任務是否已經完成，若任務完成，則傳回true；

get()方法用來擷取執行結果，這個方法會産生阻塞，會一直等到任務執行完畢才傳回；

get(long timeout, TimeUnit unit)用來擷取執行結果，如果在指定時間内，還沒擷取到結果，就直接傳回null。

　　也就是說Future提供了三種功能：

　　1）判斷任務是否完成；

　　2）能夠中斷任務；

　　3）能夠擷取任務執行結果。

　　因為Future隻是一個接口，是以是無法直接用來建立對象使用的，是以就有了下面的FutureTask。

　　我們先來看一下FutureTask的實作：

<code>public</code> <code>class</code> <code>FutureTask&lt;V&gt; </code><code>implements</code> <code>RunnableFuture&lt;V&gt;</code>

 　　FutureTask類實作了RunnableFuture接口，我們看一下RunnableFuture接口的實作：

<code>public</code> <code>interface</code> <code>RunnableFuture&lt;V&gt; </code><code>extends</code> <code>Runnable, Future&lt;V&gt; {</code>

<code>    </code><code>void</code> <code>run();</code>

 　　可以看出RunnableFuture繼承了Runnable接口和Future接口，而FutureTask實作了RunnableFuture接口。是以它既可以作為Runnable被線程執行，又可以作為Future得到Callable的傳回值。

　　FutureTask提供了2個構造器：

<code>public</code> <code>FutureTask(Callable&lt;V&gt; callable) {</code>

<code>public</code> <code>FutureTask(Runnable runnable, V result) {</code>

　　事實上，FutureTask是Future接口的一個唯一實作類。

　　1.使用Callable+Future擷取執行結果

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

<code>public</code> <code>class</code> <code>Test {</code>

<code>    </code><code>public</code> <code>static</code> <code>void</code> <code>main(String[] args) {</code>

<code>        </code><code>ExecutorService executor = Executors.newCachedThreadPool();</code>

<code>        </code><code>Task task = </code><code>new</code> <code>Task();</code>

<code>        </code><code>Future&lt;Integer&gt; result = executor.submit(task);</code>

<code>        </code><code>executor.shutdown();</code>

<code>        </code> 

<code>        </code><code>try</code> <code>{</code>

<code>            </code><code>Thread.sleep(</code><code>1000</code><code>);</code>

<code>        </code><code>} </code><code>catch</code> <code>(InterruptedException e1) {</code>

<code>            </code><code>e1.printStackTrace();</code>

<code>        </code><code>}</code>

<code>        </code><code>System.out.println(</code><code>"主線程在執行任務"</code><code>);</code>

<code>            </code><code>System.out.println(</code><code>"task運作結果"</code><code>+result.get());</code>

<code>        </code><code>} </code><code>catch</code> <code>(InterruptedException e) {</code>

<code>            </code><code>e.printStackTrace();</code>

<code>        </code><code>} </code><code>catch</code> <code>(ExecutionException e) {</code>

<code>        </code><code>System.out.println(</code><code>"所有任務執行完畢"</code><code>);</code>

<code>    </code><code>}</code>

<code>class</code> <code>Task </code><code>implements</code> <code>Callable&lt;Integer&gt;{</code>

<code>    </code><code>@Override</code>

<code>    </code><code>public</code> <code>Integer call() </code><code>throws</code> <code>Exception {</code>

<code>        </code><code>System.out.println(</code><code>"子線程在進行計算"</code><code>);</code>

<code>        </code><code>Thread.sleep(</code><code>3000</code><code>);</code>

<code>        </code><code>int</code> <code>sum = </code><code>0</code><code>;</code>

<code>        </code><code>for</code><code>(</code><code>int</code> <code>i=</code><code>0</code><code>;i&lt;</code><code>100</code><code>;i++)</code>

<code>            </code><code>sum += i;</code>

<code>        </code><code>return</code> <code>sum;</code>

 　　執行結果：

 View Code

　　2.使用Callable+FutureTask擷取執行結果

38

39

40

41

42

43

44

45

<code>        </code><code>//第一種方式</code>

<code>        </code><code>FutureTask&lt;Integer&gt; futureTask = </code><code>new</code> <code>FutureTask&lt;Integer&gt;(task);</code>

<code>        </code><code>executor.submit(futureTask);</code>

<code>        </code><code>//第二種方式，注意這種方式和第一種方式效果是類似的，隻不過一個使用的是ExecutorService，一個使用的是Thread</code>

<code>        </code><code>/*Task task = new Task();</code>

<code>        </code><code>FutureTask&lt;Integer&gt; futureTask = new FutureTask&lt;Integer&gt;(task);</code>

<code>        </code><code>Thread thread = new Thread(futureTask);</code>

<code>        </code><code>thread.start();*/</code>

<code>            </code><code>System.out.println(</code><code>"task運作結果"</code><code>+futureTask.get());</code>

 　　如果為了可取消性而使用 Future 但又不提供可用的結果，則可以聲明 Future&lt;?&gt; 形式類型、并傳回 null 作為底層任務的結果。