Callable與 Future 兩功能是Java在后續版本中為了適應多并法才加入的，Callable是類似于Runnable的接口，實現Callable接口的類和實現Runnable的類都是可被其他線程執行的任務。
Callable的接口定義如下；
|
1
2
3
4
5
|
public interface Callable<V> { V call() throws Exception; <span id="transmark"></span>} |
Callable和Runnable的區別如下：
I Callable定義的方法是call，而Runnable定義的方法是run。
II Callable的call方法可以有返回值，而Runnable的run方法不能有返回值。
III Callable的call方法可拋出異常，而Runnable的run方法不能拋出異常。
Future 介紹
Future表示異步計算的結果，它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結果。Future的cancel方法可以取消任務的執行，它有一布爾參數，參數為 true 表示立即中斷任務的執行，參數為 false 表示允許正在運行的任務運行完成。Future的 get 方法等待計算完成，獲取計算結果
|
1
2
3
4
5
6
7
8
9
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;/** * Callable 和 Future接口 * Callable是類似于Runnable的接口，實現Callable接口的類和實現Runnable的類都是可被其它線程執行的任務。 * Callable和Runnable有幾點不同： * （1）Callable規定的方法是call()，而Runnable規定的方法是run(). * （2）Callable的任務執行后可返回值，而Runnable的任務是不能返回值的。 * （3）call()方法可拋出異常，而run()方法是不能拋出異常的。 * （4）運行Callable任務可拿到一個Future對象， * Future 表示異步計算的結果。它提供了檢查計算是否完成的方法，以等待計算的完成，并檢索計算的結果。 * 通過Future對象可了解任務執行情況，可取消任務的執行，還可獲取任務執行的結果。 */public class CallableAndFuture { public static class MyCallable implements Callable{ private int flag = 0; public MyCallable(int flag){ this.flag = flag; } public String call() throws Exception{ if (this.flag == 0){ return "flag = 0"; } if (this.flag == 1){ try { while (true) { System.out.println("looping."); Thread.sleep(2000); } } catch (InterruptedException e) { System.out.println("Interrupted"); } return "false"; } else { throw new Exception("Bad flag value!"); } } } public static void main(String[] args) { // 定義3個Callable類型的任務 MyCallable task1 = new MyCallable(0); MyCallable task2 = new MyCallable(1); MyCallable task3 = new MyCallable(2); // 創建一個執行任務的服務 ExecutorService es = Executors.newFixedThreadPool(3); try { // 提交并執行任務，任務啟動時返回了一個Future對象， // 如果想得到任務執行的結果或者是異常可對這個Future對象進行操作 Future future1 = es.submit(task1); // 獲得第一個任務的結果，如果調用get方法，當前線程會等待任務執行完畢后才往下執行 System.out.println("task1: " + future1.get()); Future future2 = es.submit(task2); // 等待5秒后，再停止第二個任務。因為第二個任務進行的是無限循環 Thread.sleep(5000); System.out.println("task2 cancel: " + future2.cancel(true)); // 獲取第三個任務的輸出，因為執行第三個任務會引起異常 // 所以下面的語句將引起異常的拋出 Future future3 = es.submit(task3); System.out.println("task3: " + future3.get()); } catch (Exception e){ System.out.println(e.toString()); } // 停止任務執行服務 es.shutdownNow(); }} |
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
