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