标签：exe rgs source exception 开始 操作 sub 完成 abstract
Runnable和Callable<v>、Future及其实现类FutureTask对比Runnable和Callable<v>都是任务的抽象类，不同的是前者不会返回值，后者有返回值。两者源码如下：
Runnable
@FunctionalInterface
public interface Runnable {
public abstract void run();
}Callable<V>
@FunctionalInterface
public interface Callable<V> {
V call() throws Exception;
}Future及其实现类FutureTask用来获取异步计算结果的，说白了就是对具体的Runnable或者Callable对象任务执行的结果进行获取get() get(x,y),取消cancel(),判断是否完成isDone()和是否取消isCancelled()等操作。其源码如下：
public interface Future<V> {
//尝试取消任务的执行，如果任务已经完成或者取消，则会尝试将会失败。
//如果参数是true，表示正在执行的任务可以中断，
//此方法执行后，isDone总会返回true；如果返回true则isCancelled返回true；
boolean cancel(boolean mayInterruptIfRunning);
//如果任务在完成之前取消，返回true
boolean isCancelled();
//任务完成则返回TRUE，完成指正常结束、异常或者取消；
boolean isDone();
//阻塞获取计算的完成，并且获取结果
V get() throws InterruptedException, ExecutionException;
//在指定的时间内阻塞获取计算结果
V get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}可以作为线程池ThreadPoolExecutor的方法public <T> Future<T> submit(Callable<T> task)的返回值，其get()方法可以阻塞获取Callable的call()计算结果。
FutureTaskFutureTask是RunnableFuture<v>的实现类，而RunnableFuture<V>是Runnable和Future的子接口(接口可以多继承)。**注意FutureTask实现了Runnable接口。
展示使用Callable<V>+Future<V>和Callable<V>+FutureTask<V>提交有返回值的任务，并且异步获取返回值。
Callable<V>+Future<V>：提交Callable并获取Future类型的返回结果；Callable<V>+FutureTask<V>:将Callable作为构造器参数，将自己并提交执行，然后使用其get获取结果。CallableTask
public class CallableTask implements Callable<Integer> {
@Override
public Integer call() throws InterruptedException {
System.out.println("开始执行任务");
TimeUnit.SECONDS.sleep(1);
int sum=0;
for (int i = 0; i < 100; i++) {
sum+=i;
}
System.out.println("结束任务执行");
return new Integer(sum);
}
}FutureDemo
public class FutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor= Executors.newCachedThreadPool();
//fixme 提交Callable并获取Future类型的返回结果
CallableTask task=new CallableTask();
Future<Integer> res=executor.submit(task);
executor.shutdown();
System.out.println("计算结果："+res.get());
}
}FutureTaskDemo
public class FutureTaskDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor= Executors.newCachedThreadPool();
//fixme 不是直接提交Callable，而是将Callable作为构造器参数，将自己并提交执行，然后使用其get获取结果
CallableTask callableTask=new CallableTask();
FutureTask futureTask=new FutureTask(callableTask);
executor.submit(futureTask);
executor.shutdown();
System.out.println("计算结果:"+futureTask.get());
}
}output:
开始执行任务
结束任务执行
计算结果:4950标签：exe rgs source exception 开始 操作 sub 完成 abstract
原文地址：https://www.cnblogs.com/dugk/p/9042697.html
