JavaFutureTask類的用法

這篇文章主要講解了Java FutureTask類的用法，內(nèi)容清晰明了，對此有興趣的小伙伴可以學習一下，相信大家閱讀完之后會有幫助。

創(chuàng)新互聯(lián)是一家專注于成都做網(wǎng)站、網(wǎng)站設計與策劃設計,廣靈網(wǎng)站建設哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設十載,網(wǎng)設計領(lǐng)域的專業(yè)建站公司;建站業(yè)務涵蓋:廣靈等地區(qū)。廣靈做網(wǎng)站價格咨詢:028-86922220

FutureTask一個可取消的異步計算，F(xiàn)utureTask 實現(xiàn)了Future的基本方法，提空 start cancel 操作，可以查詢計算是否已經(jīng)完成，并且可以獲取計算的結(jié)果。結(jié)果只可以在計算完成之后獲取，get方法會阻塞當計算沒有完成的時候，一旦計算已經(jīng)完成，那么計算就不能再次啟動或是取消。

一個FutureTask 可以用來包裝一個 Callable 或是一個runnable對象。因為FurtureTask實現(xiàn)了Runnable方法，所以一個 FutureTask可以提交(submit)給一個Excutor執(zhí)行(excution).

FutureTask是java 5引入的一個類，從名字可以看出來FutureTask既是一個Future，又是一個Task。

我們看下FutureTask的定義：

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

FutureTask實現(xiàn)了RunnableFuture接口，RunnableFuture接口是Runnable和Future的綜合體。

作為一個Future，F(xiàn)utureTask可以執(zhí)行異步計算，可以查看異步程序是否執(zhí)行完畢，并且可以開始和取消程序，并取得程序最終的執(zhí)行結(jié)果。

除此之外，F(xiàn)utureTask還提供了一個runAndReset()的方法，該方法可以運行task并且重置Future的狀態(tài)。

Callable和Runnable的轉(zhuǎn)換
我們知道Callable是有返回值的，而Runnable是沒有返回值的。
Executors提供了很多有用的方法，將Runnable轉(zhuǎn)換為Callable：

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

FutureTask內(nèi)部包含一個Callable，并且可以接受Callable和Runnable作為構(gòu)造函數(shù)：

  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
  }

它的內(nèi)部就是調(diào)用了Executors.callable(runnable, result);方法進行轉(zhuǎn)換的。

以Runnable運行

既然是一個Runnable，那么FutureTask就可以以線程的方式執(zhí)行，我們來看一個例子：

@Test
  public void convertRunnableToCallable() throws ExecutionException, InterruptedException {
    FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
      @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());
  }

上面例子是以單個線程來執(zhí)行的，同樣我們也可以將FutureTask提交給線程池來執(zhí)行：

  @Test
  public void workWithExecutorService() throws ExecutionException, InterruptedException {
    FutureTask<Integer> futureTask = new FutureTask<>(new Callable<Integer>() {
      @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());
  }

看完上述內(nèi)容，是不是對Java FutureTask類的用法有進一步的了解，如果還想學習更多內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

新聞標題：JavaFutureTask類的用法
文章地址：http://muchs.cn/article24/jcphje.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供云服務器、靜態(tài)網(wǎng)站、微信公眾號、面包屑導航、動態(tài)網(wǎng)站、網(wǎng)站收錄

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容