Java線程池FutureTask實現原理的示例分析-創(chuàng)新互聯(lián)

這篇文章將為大家詳細講解有關Java線程池FutureTask實現原理的示例分析，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)基于成都重慶香港及美國等地區(qū)分布式IDC機房數據中心構建的電信大帶寬，聯(lián)通大帶寬，移動大帶寬，多線BGP大帶寬租用,是為眾多客戶提供專業(yè)服務器托管報價，主機托管價格性價比高，為金融證券行業(yè)內江服務器托管，ai人工智能服務器托管提供bgp線路100M獨享，G口帶寬及機柜租用的專業(yè)成都idc公司。
前言

線程池可以并發(fā)執(zhí)行多個任務，有些時候，我們可能想要跟蹤任務的執(zhí)行結果，甚至在一定時間內，如果任務沒有執(zhí)行完成，我們可能還想要取消任務的執(zhí)行，為了支持這一特性，ThreadPoolExecutor提供了 FutureTask 用于追蹤任務的執(zhí)行和取消。

類視圖

為了更好的理解FutureTask的實現原理，這里先提供幾個重要接口和類的結構，如下圖所示：

RunnableAdapter

ThreadPoolExecutor提供了submit接口用于提交任務，submit支持Runnable和Callable兩種不同的接口，為了提供統(tǒng)一的對外接口，jdk在內部把Runnable給包裝成了一個Callable，這一切是通過RunnableAdapter這個適配器來實現的。如下為RunnableAdapter的源碼：

static final class RunnableAdapter<T> implements Callable<T> {
    final Runnable task;
    final T result;
    RunnableAdapter(Runnable task, T result) {
      this.task = task;
      this.result = result;
    }
    public T call() {
      task.run();
      return result;
    }
  }

RunnableAdapter是Callable 的實現類，實現了call方法，而call方法僅僅是調用task.run(),然后return result，這樣就能夠確保在內部只需要統(tǒng)一處理Callable接口。

FutureTask實現原理

通過上一小節(jié)的了解，我們知道提交的Runnable任務在內部統(tǒng)一被轉換為Callable任務。查看submit方法的返回值，為一個Future，實際上這個Futrue為FutureTask實例，通過此實例，調用get方法，可以阻塞當前線程，直到任務運行完畢，返回結果。

整個調用鏈條如下所示：

worker thread -> futureTask.run() -> callable.call() -> task.run()

如果提交的是Callable任務，則只有前面三個調用。

為了更好的展示整個流程，下面舉例演示一遍執(zhí)行流程。

1、 向線程池submit一個Callable任務(Runnable也會被轉為Callable)， 這時候Callable被傳入一個FutureTask實例中，如下所示：

2、線程池使用一個線程，執(zhí)行這個 FutureTask 任務，

線程執(zhí)行任務過程比較簡單，最終會調用Callable.call()或者是 Runnable.run()方法，然后得到一個結果，把結果存儲在FutureTask實例的outcome屬性中，同時把狀態(tài)修改為NORMAL，表明任務已經執(zhí)行完畢，可以獲取結果了。

我們假設在執(zhí)行 callable.call() 過程中有多個線程調用了 同個FutureTask實例的get方法，這時候，這些線程會被阻塞，存于一個棧中， 如下圖所示：

線程1，2，3調用FutureTask.get方法，由于任務未執(zhí)行結束，這時候，三個線程都將被阻塞休眠，FutureTask中有一個棧，用于存放等待線程，棧頂指針為 FutureTask.waiters引用，當任務執(zhí)行完畢后，會迭代喚醒整個棧中的線程，這時候，各個線程都將被喚醒，并且可以順利拿到任務的執(zhí)行結果(執(zhí)行結果存于 FutureTask.outcome) 。

FutureTask還支持任務的取消功能，這一切都是通過 FutureTask的state狀態(tài)來協(xié)調多個線程的。

關于“Java線程池FutureTask實現原理的示例分析”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。

標題名稱：Java線程池FutureTask實現原理的示例分析-創(chuàng)新互聯(lián)
標題鏈接：http://muchs.cn/article48/dpecep.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供營銷型網站建設、App設計、網站改版、云服務器、品牌網站設計、網站營銷

廣告

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