Java并发编程：Callable、Future、FutureTask的使用
继承关系：
1、接口Callable与Runnable
1.1、Runnable接口中只有一个void run()方法,其返回值是void，执行完任务后，无法返回任何结果(只能通过操作共享变量)；
1.2、Callable接口位于java.util.concurrent包下，只有一个V call() throws Exception方法，返回一个输入类型V；
Callable需要配合ExecutorService来使用，其中声明了若干个submit方法，以下两种最常用：
Future submit(Callabletask);
Future> submit(Runnable task);
2、接口Future:
表示具体的Runnable或者Callable任务的具体的执行结果，
通过以下五种方法，实现任务的中断、是否完成、获取结果。
boolean cancel(booleanmayInterruptIfRunning)：试图取消对此任务的 执行：参数为true表示可以打断正在执行的任务。
返回false：任务已经完成；任务未完成参数为true；
返回true：任务未开始；任务未完成参数为false；
isCancelled()：如果在任务正常完成前将其取消，则返回true。。
isDone()：方法表示任务是否已经完成，若任务完成，则返回true
get()：等待计算完成返回V；
get(long timeout, TimeUnit unit):最多等待timeout时间，若结果可用返回。
3、类FutureTask：
FutureTask实现了Future和Runnable接口，有两种构造器：
public FutureTask(Callablecallable) { }public FutureTask(Runnable runnable, V result) { }
实例代码：
1、使用Callable和Future获取结果：
//使用Callable和Future获取执行结果；
public classTest {public static voidmain (String[] args){
ExecutorService executor=Executors.newCachedThreadPool();
Task task= newTask();
Future result =executor.submit(task);
executor.shutdown();try{
Thread.sleep(1000);
}catch(InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("主线程在执行任务");try{
System.out.println("task运行结果"+result.get());
}catch(InterruptedException e) {
e.printStackTrace();
}catch(ExecutionException e) {
e.printStackTrace();
}
System.out.println("所有任务执行完毕");
}
}class Task implements Callable{
@Overridepublic Integer call() throwsException {
System.out.println("子线程在进行计算");
Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)
sum+=i;returnsum;
}
}
View Code
子线程在进行计算
主线程在执行任务
task运行结果4950
所有任务执行完毕
result
2、使用Callable+FutureTask获取执行结果：
public classTest {public static voidmain(String[] args) {//第一种方式
ExecutorService executor =Executors.newCachedThreadPool();
Task task= newTask();
FutureTask futureTask = new FutureTask(task);
executor.submit(futureTask);
executor.shutdown();//第二种方式，注意这种方式和第一种方式效果是类似的，只不过一个使用的是ExecutorService，一个使用的是Thread
/*Task task = new Task();
FutureTask futureTask = new FutureTask(task);
Thread thread = new Thread(futureTask);
thread.start();*/
try{
Thread.sleep(1000);
}catch(InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("主线程在执行任务");try{
System.out.println("task运行结果"+futureTask.get());
}catch(InterruptedException e) {
e.printStackTrace();
}catch(ExecutionException e) {
e.printStackTrace();
}
System.out.println("所有任务执行完毕");
}
}class Task implements Callable{
@Overridepublic Integer call() throwsException {
System.out.println("子线程在进行计算");
Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)
sum+=i;returnsum;
}
}
View Code
子线程在进行计算
主线程在执行任务
task运行结果4950
所有任务执行完毕
result
