摘要：類是一種有效的廣泛使用的以工作隊列為基礎(chǔ)的的線程池的正確實現(xiàn)，無須嘗試編寫自己的線程池這樣容易出錯。是并發(fā)編程庫新添加的類它提供的方法可以返回各線程的返回值與接口類似于但是無法返回結(jié)果也無法返回異常。返回的結(jié)果可以被拿到。
package com.snda.sync.impl.test;
import java.util.ArrayList;
import java.util.concurrent.*;
/**
* Executor類是一種有效的廣泛使用的以工作隊列為基礎(chǔ)的的線程池的正確實現(xiàn)，無須嘗試編寫自己的線程池,這樣容易出錯。
* Callable是并發(fā)編程庫Concurrent新添加的類,它提供的call()方法可以返回各線程的返回值
* Callable 與 future :http://blog.csdn.net/ghsau/article/details/7451464
* Callable 接口類似于Runnable但是Callable無法返回結(jié)果也無法返回異常。Callable返回的結(jié)果可以被Future拿到。
* 通過submit來執(zhí)行Callable線程并取得線程的返回值
*
* 在Java中如果需要設(shè)定代碼執(zhí)行的最長時間,即超時,可以用Java的ExecutorService 類配合Future接口來實現(xiàn),Future接口
* 是Java線程的Future模式的實現(xiàn),可以來進行異步運算。
* 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();
}
}
}
}
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/64089.html
