java高并发8.1 J.U.C-- FutureTask

FutureTask

FutureTask是J.U.C中的类，是一个可删除的异步计算类。这个类提供了Future接口的的基本实现，使用相关方法启动和取消计算，查询计算是否完成，并检索计算结果。只有在计算完成时才能使用get方法检索结果;如果计算尚未完成，get方法将会阻塞。一旦计算完成，计算就不能重新启动或取消(除非使用runAndReset方法调用计算)。

Runnable与Callable对比

通常实现一个线程我们会使用继承Thread的方式或者实现Runnable接口，这两种方式有一个共同的缺陷就是在执行完任务之后无法获取执行结果。从Java1.5之后就提供了Callable与Future，这两个接口就可以实现获取任务执行结果。

 

Runnable接口：代码非常简单，只有一个方法run

public interface RunnableFuture<V> extends Runnable, Future<V> {

    void run();

}

 

Callable泛型接口：有泛型参数，提供了一个call方法，执行后可返回传入的泛型参数类型的结果。

public interface Callable<V> {

    V call() throws Exception;

}

 

Future接口

Future接口提供了一系列方法用于控制线程执行计算，如下：

public interface Future<V> {

    boolean cancel(boolean mayInterruptIfRunning);//取消任务

    boolean isCancelled();//是否被取消

    boolean isDone();//计算是否完成

    V get() throws InterruptedException, ExecutionException;//获取计算结果，在执行过程中任务被阻塞

    V get(long timeout, TimeUnit unit)//timeout等待时间、unit时间单位

        throws InterruptedException, ExecutionException, TimeoutException;

}

 

Executor就是Runnable和Callable的调度容器，Future就是对于具体的Runnable或者Callable任务的执行结果进行

取消、查询是否完成、获取结果、设置结果操作。get方法会阻塞，直到任务返回结果(Future简介)。

 

Future例子:

运行结果:

 do somet in callable 和result : Done 之间阻塞了5秒钟(程序里的)

 

FutureTask

Future实现了RunnableFuture接口，而RunnableFuture接口继承了Runnable与Future接口，所以它既可以作为Runnable被线程中执行，又可以作为callable获得返回值。

例子:

输出结果:

可以看到结果和Future是一样的

FutureTask支持两种参数类型，Callable和Runnable，在使用Runnable 时，还可以多指定一个返回结果类型。

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

}