Callable、Future和FutureTask
前言：如有不正确的地方，还望指正。
目录
- 认识cpu、核心与线程
- java多线程系列（一）之java多线程技能
- java多线程系列（二）之对象变量的并发访问
- java多线程系列（三）之等待通知机制
- java多线程系列（四）之ReentrantLock的使用
- java多线程系列（五）之synchronized ReentrantLock volatile Atomic 原理分析
- java多线程系列（六）之线程池原理及其使用
- java多线程系列(七)---Callable、Future和FutureTask
Callable
- Callable接口和Runnable接口的作用类似
- 不同的是Callble接口call方法有返回值，返回的是传进来的V类型，而Runnable接口run方法无返回值
public interface Runnable {
public abstract void run();
}
public interface Callable<V> {
V call() throws Exception;
}
Future
- Futurue是一个接口，Future 表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并获取计算的结果。计算完成后只能使用 get 方法来获取结果，如有必要，计算完成前可以阻塞此方法。取消则由 cancel 方法来执行。还提供了其他方法，以确定任务是正常完成还是被取消了。一旦计算完成，就不能再取消计算。如果为了可取消性而使用 Future 但又不提供可用的结果，则可以声明 Future<?> 形式类型、并返回 null 作为底层任务的结果。
- Cancel方法：试图取消任务的执行，如果任务已完成或者已取消或者无法取消，则返回false。如果任务尚未启动，执行此方法后，将不会再运行。如果任务已经启动，则可以选择参数确定是否尝试停止任务
- isCancelled方法：如果任务正常完成前将其取消，返回true
- get方法：等待计算完成，然后获取结果
- isDone方法：如果任务完成，返回true
public interface Future<V> {
boolean cancel(boolean mayInterruptIfRunning);
boolean isCancelled();
boolean isDone();
V get() throws InterruptedException, ExecutionException;
V get(long timeout, TimeUnit unit)
throws InterruptedException, ExecutionException, TimeoutException;
}
FutureTask
- FutureTask是一个类，实现了RunnableFuture接口，而RunnableFuture接口继承了Runnable和Future接口
- FutureTask的有两个构造方法，参数是Callable和Runnable
public class FutureTask<V> implements RunnableFuture<V>
{
public FutureTask(Callable<V> callable) {
if (callable == null)
throw new NullPointerException();
this.callable = callable;
this.state = NEW; // ensure visibility of callable
}
public FutureTask(Runnable runnable, V result) {
this.callable = Executors.callable(runnable, result);
this.state = NEW; // ensure visibility of callable
}
}
public interface RunnableFuture<V> extends Runnable, Future<V> {
void run();
}
AbstractExecutorService的submit方法
AbstractExecutorService是一个抽象类，也是ThreadPoolExecutor的父类
public class ThreadPoolExecutor extends AbstractExecutorService
public Future<?> submit(Runnable task)public <T> Future <T> submit< Runnable task, T result>public <T> Future<T> submit < Callable <T> task >对比ThreadPoolThread的execute方法，execute无返回值，而三个submit方法返回的都是Future，可以获取任务执行结果，还可以取消任务
使用
- Future用法
public static void main(String[] args)
{
ThreadPoolExecutor tp = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
Future<String> future=tp.submit(new Callable<String>()
{
public String call() throws Exception {
// TODO 自动生成的方法存根
return "jiajun";
}
});
tp.shutdown();
try {
System.out.println(future.get());
System.out.println(future.isCancelled());
System.out.println(future.isDone());
System.out.println(future.cancel(true));
} catch (InterruptedException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
} catch (ExecutionException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}
}
- FutureTask用法
public static void main(String[] args)
{
ThreadPoolExecutor tp = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
FutureTask <String >future= new FutureTask<String>(new Callable<String>()
{
public String call() throws Exception {
// TODO 自动生成的方法存根
return "jiajun";
}
});
tp.submit(future);
tp.shutdown();
try {
System.out.println(future.get());
System.out.println(future.isCancelled());
System.out.println(future.isDone());
System.out.println(future.cancel(true));
} catch (InterruptedException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
} catch (ExecutionException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}
}
- 不同的地方，从代码可以看出第一份代码中future作为submit方法的返回值，而第二份代码，futureTask作为submit方法的参数。
总结
- Callable和Runable都是接口，二者作用类似，不同的是Callable有返回值，而Runnable无返回值
- Callable一般和ExecutorService一起使用，其返回的值是submit方法返回的Future得到的
- Future可以查看任务执行情况，可以取消任务
- 有时候并不需要返回值，但是由于需要可取消任务，所以使用submit方法而不使用execute方法
- FutureTask是一个类，实现了RunnableFuture接口（继承了Runnable和Future接口），FutureTask可以做为submit方法的参数，并通过FutureTask可以查看任务执行状态
我觉得分享是一种精神，分享是我的乐趣所在，不是说我觉得我讲得一定是对的，我讲得可能很多是不对的，但是我希望我讲的东西是我人生的体验和思考，是给很多人反思，也许给你一秒钟、半秒钟，哪怕说一句话有点道理，引发自己内心的感触，这就是我最大的价值。（这是我喜欢的一句话，也是我写博客的初衷）
作者：jiajun 出处： http://www.cnblogs.com/-new/
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则保留追究法律责任的权利。如果觉得还有帮助的话，可以点一下右下角的【推荐】，希望能够持续的为大家带来好的技术文章！想跟我一起进步么？那就【关注】我吧。