Runnable 是执行工作的独立任务,但是它不返回任何值。如果希望任务在完成时能够返回一个值,那么可以实现Callable 接口而不是 Runnable 接口。 在 Java SE5 中引入的 Callable 是一个具有类型参数的泛型,它的类型参数表示的是从方法 call() 中返回的值 必须使用ExecutorService.submit() 方法调用实现Callable接口的类的对象 submit方法会产生Future对象,它用Callable返回结果的类型进行了参数化。
示例
代码语言:javascript复制import java.util.ArrayList;
import java.util.concurrent.*;
/**
* Callable Future使用示例
* User: pengyapan
* Date: 2020/4/16
* Time: 上午10:51
*/
public class TestCallable {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
ArrayList<Future<String>> results = new ArrayList<Future<String>>();
for(int i = 0; i < 10; i ){
results.add(executorService.submit(new TaskWithResult(i))); // submit方法会产生Future对象,它用Callable返回结果的类型进行了参数化。
}
for(Future<String> fs : results){
try {
System.out.println(fs.get());
} catch (InterruptedException e) {
System.out.println(e);
return;
} catch (ExecutionException e) {
System.out.println(e);
return;
}finally {
executorService.shutdown();
}
}
}
}
class TaskWithResult implements Callable<String>{
private int id;
public TaskWithResult(int id){
this.id = id;
}
public String call() throws Exception {
return "result of TaskWithResult " id;
}
}