JavaFutureTask类的用法-成都快上网建站

JavaFutureTask类的用法

这篇文章主要讲解了Java FutureTask类的用法,内容清晰明了,对此有兴趣的小伙伴可以学习一下,相信大家阅读完之后会有帮助。

创新互联是一家专注于成都做网站、网站设计与策划设计,广灵网站建设哪家好?创新互联做网站,专注于网站建设十载,网设计领域的专业建站公司;建站业务涵盖:广灵等地区。广灵做网站价格咨询:028-86922220

FutureTask一个可取消的异步计算,FutureTask 实现了Future的基本方法,提空 start cancel 操作,可以查询计算是否已经完成,并且可以获取计算的结果。结果只可以在计算完成之后获取,get方法会阻塞当计算没有完成的时候,一旦计算已经完成,那么计算就不能再次启动或是取消。

一个FutureTask 可以用来包装一个 Callable 或是一个runnable对象。因为FurtureTask实现了Runnable方法,所以一个 FutureTask可以提交(submit)给一个Excutor执行(excution).

FutureTask是java 5引入的一个类,从名字可以看出来FutureTask既是一个Future,又是一个Task。

我们看下FutureTask的定义:

public class FutureTask implements RunnableFuture {
  ...
}
public interface RunnableFuture extends Runnable, Future {
  /**
   * Sets this Future to the result of its computation
   * unless it has been cancelled.
   */
  void run();
}

FutureTask实现了RunnableFuture接口,RunnableFuture接口是Runnable和Future的综合体。

作为一个Future,FutureTask可以执行异步计算,可以查看异步程序是否执行完毕,并且可以开始和取消程序,并取得程序最终的执行结果。

除此之外,FutureTask还提供了一个runAndReset()的方法, 该方法可以运行task并且重置Future的状态。

Callable和Runnable的转换
我们知道Callable是有返回值的,而Runnable是没有返回值的。
Executors提供了很多有用的方法,将Runnable转换为Callable:

  public static  Callable callable(Runnable task, T result) {
    if (task == null)
      throw new NullPointerException();
    return new RunnableAdapter(task, result);
  }

FutureTask内部包含一个Callable,并且可以接受Callable和Runnable作为构造函数:

  public FutureTask(Callable 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
  }

它的内部就是调用了Executors.callable(runnable, result);方法进行转换的。

以Runnable运行

既然是一个Runnable,那么FutureTask就可以以线程的方式执行,我们来看一个例子:

@Test
  public void convertRunnableToCallable() throws ExecutionException, InterruptedException {
    FutureTask futureTask = new FutureTask<>(new Callable() {
      @Override
      public Integer call() throws Exception {
        log.info("inside callable future task ...");
        return 0;
      }
    });

    Thread thread= new Thread(futureTask);
    thread.start();
    log.info(futureTask.get().toString());
  }

上面例子是以单个线程来执行的,同样我们也可以将FutureTask提交给线程池来执行:

  @Test
  public void workWithExecutorService() throws ExecutionException, InterruptedException {
    FutureTask futureTask = new FutureTask<>(new Callable() {
      @Override
      public Integer call() throws Exception {
        log.info("inside futureTask");
        return 1;
      }
    });
    ExecutorService executor = Executors.newCachedThreadPool();
    executor.submit(futureTask);
    executor.shutdown();
    log.info(futureTask.get().toString());
  }

看完上述内容,是不是对Java FutureTask类的用法有进一步的了解,如果还想学习更多内容,欢迎关注创新互联行业资讯频道。


文章名称:JavaFutureTask类的用法
分享URL:http://kswjz.com/article/jcphje.html
扫二维码与项目经理沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流