Callable和Future用法示例
1.Callable 和 Future接口
Callable是類似於Runnable的接口,實現Callable接口的類和實現Runnable的類都是可被其它線程執行的任務。
Callable和Runnable有幾點不同:
(1)Callable規定的方法是call(),而Runnable規定的方法是run().
(2)Callable的任務執行後可返回值,而Runnable的任務是不能返回值的。
(3)call()方法可拋出異常,而run()方法是不能拋出異常的。
(4)運行Callable任務可拿到一個Future對象, Future表示異步計算的結果。
- 它提供了檢查計算是否完成的方法,以等待計算的完成,並檢索計算的結果。
- 通過Future對象可了解任務執行情況,可取消任務的執行,還可獲取任務執行的結果。
2.註意事項如下:
Future取得的結果類型和Callable返回的結果類型必須一致,這是通過泛型來實現的。
Callable要采用ExecutorSevice的submit方法提交,返回的future對象可以取消任務。
CompletionService用於提交一組Callable任務,其take方法返回已完成的一個Callable任務對應的Future對象。
3.Java示例代碼:
3.1 Callable接口的使用:
package com.chang;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
public class CallableAndFuture {
public static void main(String[] args) throws Exception { //創建一個固定大小的線程池 ExecutorService pool = Executors.newFixedThreadPool(1); // 向線程池提交一個線程任務,這個線程任務返回一句話 Future<String> future = pool.submit(new Callable<String>() { @Override public String call() throws Exception { return "科大訊飛是中國最大的語音提供商"; } }); //獲取線程執行的結果 System.out.println(future.get());; MyTask task = new MyTask(); Future<String> futrue2 = pool.submit(task); //取消線程任務 futrue2.cancel(true); System.out.println("任務已經取消:"+futrue2.isCancelled()); System.out.println("返回結果======"+futrue2.get()); System.out.println(future.get(1, TimeUnit.SECONDS)); } public static class MyTask implements Callable<String>{ @Override public String call() throws Exception { return "科大訊飛是中國最大的語音提供商"; } }
}
3.2. 提交一組任務,返回一組任務的結果;
package com.chang;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableAdnFuture2 {
public static void main(String[] args) throws Exception {
ExecutorService pool = Executors.newFixedThreadPool(10);
CompletionService<Integer> service = new ExecutorCompletionService<Integer>(pool);
for(int i=0;i<10;i++) {
final int num = i;
service.submit(new Callable<Integer>() {
@Override
public Integer call() throws Exception {
return num;
}
});
}
for(int i=0;i<9;i++) {
Future<Integer> result = service.take();
System.out.println(result.get());
}
}
}
Callable和Future用法示例