創(chuàng)新互聯(lián)主營(yíng)道里網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,成都App定制開(kāi)發(fā),道里h5小程序定制開(kāi)發(fā)搭建,道里網(wǎng)站營(yíng)銷(xiāo)推廣歡迎道里等地區(qū)企業(yè)咨詢

（手機(jī)橫屏看源碼更方便）

---

注：java源碼分析部分如無(wú)特殊說(shuō)明均基于 java8 版本。

簡(jiǎn)介

Java的線程池是塊硬骨頭，對(duì)線程池的源碼做深入研究不僅能提高對(duì)Java整個(gè)并發(fā)編程的理解，也能提高自己在面試中的表現(xiàn)，增加被錄取的可能性。

本系列將分成很多個(gè)章節(jié)，本章作為線程池的第一章將對(duì)整個(gè)線程池體系做一個(gè)總覽。

體系結(jié)構(gòu)

上圖列舉了線程池中非常重要的接口和類(lèi)：

（1）Executor，線程池頂級(jí)接口；

（2）ExecutorService，線程池次級(jí)接口，對(duì)Executor做了一些擴(kuò)展，增加一些功能；

（3）ScheduledExecutorService，對(duì)ExecutorService做了一些擴(kuò)展，增加一些定時(shí)任務(wù)相關(guān)的功能；

（4）AbstractExecutorService，抽象類(lèi)，運(yùn)用模板方法設(shè)計(jì)模式實(shí)現(xiàn)了一部分方法；

（5）ThreadPoolExecutor，普通線程池類(lèi)，這也是我們通常所說(shuō)的線程池，包含最基本的一些線程池操作相關(guān)的方法實(shí)現(xiàn)；

（6）ScheduledThreadPoolExecutor，定時(shí)任務(wù)線程池類(lèi)，用于實(shí)現(xiàn)定時(shí)任務(wù)相關(guān)功能；

（7）ForkJoinPool，新型線程池類(lèi)，java7中新增的線程池類(lèi)，基于工作竊取理論實(shí)現(xiàn)，運(yùn)用于大任務(wù)拆小任務(wù)、任務(wù)無(wú)限多的場(chǎng)景；

（8）Executors，線程池工具類(lèi)，定義了一些快速實(shí)現(xiàn)線程池的方法（謹(jǐn)慎使用）；

Executor

線程池頂級(jí)接口，只定義了一個(gè)執(zhí)行無(wú)返回值任務(wù)的方法。

public interface Executor {
    // 執(zhí)行無(wú)返回值任務(wù)，本文由公從號(hào)“彤哥讀源碼”原創(chuàng)
    void execute(Runnable command);
}

ExecutorService

線程池次級(jí)接口，對(duì)Executor做了一些擴(kuò)展，主要增加了關(guān)閉線程池、執(zhí)行有返回值任務(wù)、批量執(zhí)行任務(wù)的方法。

public interface ExecutorService extends Executor {
    // 關(guān)閉線程池，不再接受新任務(wù)，但已經(jīng)提交的任務(wù)會(huì)執(zhí)行完成
    void shutdown();

    // 立即關(guān)閉線程池，嘗試停止正在運(yùn)行的任務(wù)，未執(zhí)行的任務(wù)將不再執(zhí)行
    // 被迫停止及未執(zhí)行的任務(wù)將以列表的形式返回
    List<Runnable> shutdownNow();

    // 檢查線程池是否已關(guān)閉
    boolean isShutdown();

    // 檢查線程池是否已終止，只有在shutdown()或shutdownNow()之后調(diào)用才有可能為true
    boolean isTerminated();

    // 在指定時(shí)間內(nèi)線程池達(dá)到終止?fàn)顟B(tài)了才會(huì)返回true
    boolean awaitTermination(long timeout, TimeUnit unit)
        throws InterruptedException;

    // 執(zhí)行有返回值的任務(wù)，任務(wù)的返回值為task.call()的結(jié)果
    <T> Future<T> submit(Callable<T> task);

    // 執(zhí)行有返回值的任務(wù)，任務(wù)的返回值為這里傳入的result
    // 當(dāng)然只有當(dāng)任務(wù)執(zhí)行完成了調(diào)用get()時(shí)才會(huì)返回
    <T> Future<T> submit(Runnable task, T result);

    // 執(zhí)行有返回值的任務(wù)，任務(wù)的返回值為null
    // 當(dāng)然只有當(dāng)任務(wù)執(zhí)行完成了調(diào)用get()時(shí)才會(huì)返回
    Future<?> submit(Runnable task);

    // 批量執(zhí)行任務(wù)，只有當(dāng)這些任務(wù)都完成了這個(gè)方法才會(huì)返回
    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
        throws InterruptedException;

    // 在指定時(shí)間內(nèi)批量執(zhí)行任務(wù)，未執(zhí)行完成的任務(wù)將被取消
    // 這里的timeout是所有任務(wù)的總時(shí)間，不是單個(gè)任務(wù)的時(shí)間
    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                  long timeout, TimeUnit unit)
        throws InterruptedException;

    // 返回任意一個(gè)已完成任務(wù)的執(zhí)行結(jié)果，未執(zhí)行完成的任務(wù)將被取消
    <T> T invokeAny(Collection<? extends Callable<T>> tasks)
        throws InterruptedException, ExecutionException;

    // 在指定時(shí)間內(nèi)如果有任務(wù)已完成，則返回任意一個(gè)已完成任務(wù)的執(zhí)行結(jié)果，未執(zhí)行完成的任務(wù)將被取消
    <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                    long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}

ScheduledExecutorService

對(duì)ExecutorService做了一些擴(kuò)展，增加一些定時(shí)任務(wù)相關(guān)的功能，主要包含兩大類(lèi)：執(zhí)行一次，重復(fù)多次執(zhí)行。

public interface ScheduledExecutorService extends ExecutorService {

    // 在指定延時(shí)后執(zhí)行一次
    public ScheduledFuture<?> schedule(Runnable command,
                                       long delay, TimeUnit unit);
    // 在指定延時(shí)后執(zhí)行一次
    public <V> ScheduledFuture<V> schedule(Callable<V> callable,
                                           long delay, TimeUnit unit);

    // 在指定延時(shí)后開(kāi)始執(zhí)行，并在之后以指定時(shí)間間隔重復(fù)執(zhí)行（間隔不包含任務(wù)執(zhí)行的時(shí)間）
    // 相當(dāng)于之后的延時(shí)以任務(wù)開(kāi)始計(jì)算，本文由公從號(hào)“彤哥讀源碼”原創(chuàng)
    public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                                  long initialDelay,
                                                  long period,
                                                  TimeUnit unit);

    // 在指定延時(shí)后開(kāi)始執(zhí)行，并在之后以指定延時(shí)重復(fù)執(zhí)行（間隔包含任務(wù)執(zhí)行的時(shí)間）
    // 相當(dāng)于之后的延時(shí)以任務(wù)結(jié)束計(jì)算
    public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                     long initialDelay,
                                                     long delay,
                                                     TimeUnit unit);

}

AbstractExecutorService

抽象類(lèi)，運(yùn)用模板方法設(shè)計(jì)模式實(shí)現(xiàn)了一部分方法，主要為執(zhí)行有返回值任務(wù)、批量執(zhí)行任務(wù)的方法。

public abstract class AbstractExecutorService implements ExecutorService {

    protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
        return new FutureTask<T>(runnable, value);
    }

    protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
        return new FutureTask<T>(callable);
    }

    public Future<?> submit(Runnable task) {
        if (task == null) throw new NullPointerException();
        RunnableFuture<Void> ftask = newTaskFor(task, null);
        execute(ftask);
        return ftask;
    }

    public <T> Future<T> submit(Runnable task, T result) {
        if (task == null) throw new NullPointerException();
        RunnableFuture<T> ftask = newTaskFor(task, result);
        execute(ftask);
        return ftask;
    }

    public <T> Future<T> submit(Callable<T> task) {
        if (task == null) throw new NullPointerException();
        RunnableFuture<T> ftask = newTaskFor(task);
        execute(ftask);
        return ftask;
    }

    public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
        throws InterruptedException, ExecutionException {
        // 略...
    }

    public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                           long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException {
        // 略...
    }

    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
        throws InterruptedException {
        // 略...
    }

    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                         long timeout, TimeUnit unit)
        throws InterruptedException {
        // 略...
    }

}

可以看到，這里的submit()方法對(duì)傳入的任務(wù)都包裝成了FutureTask來(lái)進(jìn)行處理，這是什么東西呢？歡迎關(guān)注后面的章節(jié)。

ThreadPoolExecutor

普通線程池類(lèi)，這也是我們通常所說(shuō)的線程池，包含最基本的一些線程池操作相關(guān)的方法實(shí)現(xiàn)。

線程池的主要實(shí)現(xiàn)邏輯都在這里面，比如線程的創(chuàng)建、任務(wù)的處理、拒絕策略等，我們后面單獨(dú)分析這個(gè)類(lèi)。

ScheduledThreadPoolExecutor

定時(shí)任務(wù)線程池類(lèi)，用于實(shí)現(xiàn)定時(shí)任務(wù)相關(guān)功能，將任務(wù)包裝成定時(shí)任務(wù)，并按照定時(shí)策略來(lái)執(zhí)行，我們后面單獨(dú)分析這個(gè)類(lèi)。

問(wèn)題：你知道定時(shí)任務(wù)線程池類(lèi)使用的是什么隊(duì)列嗎？

ForkJoinPool

新型線程池類(lèi)，java7中新增的線程池類(lèi)，這個(gè)線程池與Go中的線程模型特別類(lèi)似，都是基于工作竊取理論，特別適合于處理歸并排序這種先分后合的場(chǎng)景。

Executors

線程池工具類(lèi)，定義了一系列快速實(shí)現(xiàn)線程池的方法——newXXX()，不過(guò)阿里手冊(cè)是不建議使用這個(gè)類(lèi)來(lái)新建線程池的，彤哥我并不這么認(rèn)為，只要能掌握其源碼，知道其利敝偶爾還是可以用的，后面我們?cè)賮?lái)說(shuō)這個(gè)事。

彩蛋

無(wú)彩蛋不歡，今天的問(wèn)題是定時(shí)任務(wù)線程池用的是哪種隊(duì)列來(lái)實(shí)現(xiàn)的？

答：延時(shí)隊(duì)列。定時(shí)任務(wù)線程池中并沒(méi)有直接使用并發(fā)集合中的DelayQueue，而是自己又實(shí)現(xiàn)了一個(gè)DelayedWorkQueue，不過(guò)跟DelayQueue的實(shí)現(xiàn)原理是一樣的。

延時(shí)隊(duì)列使用什么數(shù)據(jù)結(jié)構(gòu)來(lái)實(shí)現(xiàn)的呢？

答：堆（DelayQueue中使用的是優(yōu)先級(jí)隊(duì)列，而優(yōu)先級(jí)隊(duì)列使用的堆；DelayedWorkQueue直接使用的堆）。

關(guān)于延時(shí)隊(duì)列、優(yōu)先級(jí)隊(duì)列和堆的相關(guān)內(nèi)容點(diǎn)擊下面的鏈接直達(dá)：

死磕 java集合之DelayQueue源碼分析

死磕 java集合之PriorityQueue源碼分析

拜托，面試別再問(wèn)我堆（排序）了！

創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國(guó)云服務(wù)器，動(dòng)態(tài)BGP最優(yōu)骨干路由自動(dòng)選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動(dòng)現(xiàn)已開(kāi)啟，新人活動(dòng)云服務(wù)器買(mǎi)多久送多久。

文章名稱：死磕java線程系列之線程池深入解析——體系結(jié)構(gòu)-創(chuàng)新互聯(lián)
分享URL：http://chinadenli.net/article12/cdoggc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站維護(hù)、標(biāo)簽優(yōu)化、移動(dòng)網(wǎng)站建設(shè)、服務(wù)器托管、網(wǎng)站導(dǎo)航、面包屑導(dǎo)航

廣告

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