Callable和Future的使用
通常我们创建线程使用new Thread 和实现Runnable接口，但是这两种方式有一个缺陷，就是不能返回线程执行的结果，Doug lea又给我们提供了另一种方式，实现Callable接口，Callable只有一个方法，它是有返回值的，也可以抛出异常，它的执行结果可以被Future拿到。
Callable
- Callable和Future，它俩很有意思的，一个产生结果，一个拿到结果。
- Future表示一个可能还没有完成的异步任务的结果，针对这个结果可以添加Callback以便在任务执行成功或失败后作出相应的操作。
- Callable接口中只有一个call()方法，和Runnable相比，该方法有返回值并允许抛出异常
- FutureTask是Runnable, Future接口的实现类。
RunnableFuture
- 这个接口同时继承Future接口和Runnable接口，在成功执行run（）方法后，可以通过Future访问执行结果。这个接口都实现类是FutureTask,一个可取消的异步计算，这个类提供了Future的基本实现，后面我们的demo也是用这个类实现，它实现了启动和取消一个计算，查询这个计算是否已完成，恢复计算结果。计算的结果只能在计算已经完成的情况下恢复。如果计算没有完成，get方***阻塞，一旦计算完成，这个计算将不能被重启和取消，除非调用runAndReset方法。
- FutureTask能用来包装一个Callable或Runnable对象，因为它实现了Runnable接口，而且它能被传递到Executor进行执行。为了提供单例类，这个类在创建自定义的工作类时提供了protected构造函数
Future是一个接口，它可以对Callable任务的执行结果进行操作。
boolean cancel(boolean mayInterruptIfRunning);
boolean isCancelled();
boolean isDone();
V get() throws InterruptedException, ExecutionException;
V get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;cancel：取消任务，取消成功返回true，取消失败返回false，mayInterruptIfRunning参数决定一个开启的任务能否被中断，如果任务已经完成，不管mayInterruptIfRunning为true或false，结果都为false，即取消完成的任务会返回false。
isCancelled：判断任务是否被取消，如果任务在正常完成前被取消直接返回true。
isDone：表示当前任务或所有的任务是否已经完成，如果任务完成，返回true。
get：获取执行结果，在这个过程中线程会一直阻塞，直到任务执行完毕，如果在此过程中，线程被中断直接抛出异常。
callable和future获取结果：
ExecutorService es = Executors.newCachedThreadPool();
java.util.concurrent.Future<String> future = es.submit(new Callable<String>() {
int i = 0;
@Override
public String call() throws Exception {
System.out.println("子线程执行过程");
for (i = 0; i < 100; i++) {
i++;
}
return "num为:" + i;
}
});
System.out.println("主线程开始执行");
try {
System.out.println("主线程取得异步结果为"+future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}看一下执行结果：
主线程开始执行
子线程执行过程
主线程取得异步结果为num为:100System.out.println("主线程doingthing");
FutureTask<Integer> futuretask = new FutureTask<>(new Callable<Integer>() {
public Integer call() throws Exception {
System.out.println("子线程执行");
int i = 0;
for (i = 0; i < 100; i++) {
i++;
}
return i;
}
});
es.execute(futuretask);
Thread.sleep(100);
System.out.println("主线程继续doing");
System.out.println("执行结果为"+futuretask.get());执行结果：
主线程doingthing
子线程执行
主线程继续doing
执行结果为100
京公网安备 11010502036488号