摘要：類是一種有效的廣泛使用的以工作隊列為基礎的的線程池的正確實現，無須嘗試編寫自己的線程池這樣容易出錯。是并發編程庫新添加的類它提供的方法可以返回各線程的返回值與接口類似于但是無法返回結果也無法返回異常。返回的結果可以被拿到。
package com.snda.sync.impl.test;
import java.util.ArrayList;
import java.util.concurrent.*;
/**
* Executor類是一種有效的廣泛使用的以工作隊列為基礎的的線程池的正確實現，無須嘗試編寫自己的線程池,這樣容易出錯。
* Callable是并發編程庫Concurrent新添加的類,它提供的call()方法可以返回各線程的返回值
* Callable 與 future :http://blog.csdn.net/ghsau/article/details/7451464
* Callable 接口類似于Runnable但是Callable無法返回結果也無法返回異常。Callable返回的結果可以被Future拿到。
* 通過submit來執行Callable線程并取得線程的返回值
*
* 在Java中如果需要設定代碼執行的最長時間,即超時,可以用Java的ExecutorService 類配合Future接口來實現,Future接口
* 是Java線程的Future模式的實現,可以來進行異步運算。
* Created by xuyifei on 14-4-22.
*/
class TaskWithResult implements Callable {
private int id;
public TaskWithResult(int id) {
this.id = id;
}
@Override
public String call() throws Exception {
return "result of TaskWithResult " + id;
}
}
public class CallableDemo {
public static void main(String[] args) {
ExecutorService exec = Executors.newCachedThreadPool();
ArrayList> results = new ArrayList<>();
for (int i = 0; i < 10; i++) {
results.add(exec.submit(new TaskWithResult(i)));
}
for (Future fs : results) {
try {
System.out.println(fs.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
} finally {
exec.shutdown();
}
}
}
}
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/64089.html
