快捷導(dǎo)航

Java多線程實(shí)現(xiàn)之Executor詳解

更新時(shí)間：2023年08月26日 09:36:56 作者：not coder

這篇文章主要介紹了Java多線程實(shí)現(xiàn)之Executor詳解,Executor 給他一個(gè) Runnable,他就能自動(dòng)很安全的幫你把這個(gè)線程執(zhí)行完畢
Executor 通過創(chuàng)建線程池的方式來管理線程,需要的朋友可以參考下

Executor 線程實(shí)現(xiàn)

        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                System.out.println("runnable 線程開始執(zhí)行");
            }
        };
        Executor executor = Executors.newCachedThreadPool();
        executor.execute(runnable);
        executor.execute(runnable);
        executor.execute(runnable);

1 Executor 簡介

Executor 給他一個(gè) Runnable，他就能自動(dòng)很安全的幫你把這個(gè)線程執(zhí)行完畢
Executor 通過創(chuàng)建線程池的方式來管理線程
Executor 有五種創(chuàng)建線程池的方式，其中 newCachedThreadPool() 是一種非常簡單的線程池創(chuàng)建方式
Executor 有兩種結(jié)束方式，shutDown() 和 shutDownNow()
- shutDown 會將當(dāng)前正在執(zhí)行的和排隊(duì)中的線程執(zhí)行完畢后結(jié)束，并且不允許有新的線程加入到待執(zhí)行隊(duì)列中
- shutDownNow 會立即結(jié)束執(zhí)行，采取的是一種比較安全的結(jié)束方式：interrupt()

2 Executor 中其他幾種創(chuàng)建線程池的方式

2.1 Executor 中的第一種線程池創(chuàng)建方式 newCachedThreadPool()

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

newCachedThreadPool() 的實(shí)現(xiàn):

在 newCachedThreadPool 中，會直接返回一個(gè) ThreadPoolExecutor，這里解釋一下創(chuàng)建 ThreadPoolExecutor 的幾個(gè)參數(shù)：

/**
	 * @param corePoolSize 代表默認(rèn)線程數(shù)，或者說最低線程數(shù)，也就是此線程池創(chuàng)建后里面立馬會有幾個(gè)線程的數(shù)量
	 * @param maximumPoolSize 代表最大線程數(shù)，超過此線程數(shù)量則排隊(duì)等待執(zhí)行，排隊(duì)線程放入最后一個(gè)參數(shù)中
	 * @param keepAliveTime 表示默認(rèn)線程數(shù)量外的已經(jīng)創(chuàng)建出來的線程在處于空閑狀態(tài)下，被回收前需要等待的時(shí)間
	 * @param unit 表示第三個(gè)時(shí)間值的單位
	 * @param workQueue 用于盛放多余任務(wù)的線程隊(duì)列
	 */
	ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue)

第一個(gè)參數(shù)代表默認(rèn)線程數(shù)，或者說最低線程數(shù)，也就是此線程池創(chuàng)建后里面立馬會有幾個(gè)線程的數(shù)量
第二個(gè)參數(shù)代表最大線程數(shù)，超過此線程數(shù)量則排隊(duì)等待執(zhí)行，排隊(duì)線程放入最后一個(gè)參數(shù)中
第三個(gè)參數(shù)表示默認(rèn)線程數(shù)量外的已經(jīng)創(chuàng)建出來的線程在處于空閑狀態(tài)下，被回收前需要等待的時(shí)間
第四個(gè)參數(shù)表示第三個(gè)時(shí)間值的單位
第五個(gè)參數(shù)用于盛放多余任務(wù)的線程隊(duì)列

例：

假如說傳入的值分別為 5，20，10L，TimeUnit.SECONDS，new SynchronousQueue< Runnable>()

則表示，創(chuàng)建一個(gè)默認(rèn)數(shù)量為 5 的線程池，這個(gè)線程池最多允許 20 條線程同時(shí)工作，如果超過 20 個(gè)則存放進(jìn)隊(duì)列中等待這 20 個(gè)線程騰出位置，每個(gè)線程執(zhí)行完畢都去隊(duì)列中取新的任務(wù)并執(zhí)行，如果隊(duì)列中沒有新的任務(wù)，則線程等待 10 秒，如果 10 后仍然沒有新的任務(wù)，則線程會被回收，一直回收到只剩余 5 個(gè)線程

2.1 Executor.newSingleThreadExecutor()

public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }

通過前兩個(gè)參數(shù)可以看出，這是創(chuàng)建單線程的線程池，也就是說這個(gè)線程池中只有一個(gè)線程，并且最多也只能有一個(gè)線程，應(yīng)用場景比較少。

2.2 Executor.newFixedThreadPool()

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

創(chuàng)建固定數(shù)量線程的線程池，通過前兩個(gè)參數(shù)可以看出，傳入的參數(shù)被同時(shí)應(yīng)用中前兩個(gè)參數(shù)中，這就意味著我創(chuàng)建一個(gè)線程池，里面的默認(rèn)線程數(shù)和最大線程數(shù)一致

并且不能擴(kuò)容、不被回收，一直放在那里，表面上可能比較合理，但實(shí)際的應(yīng)用場景也很少

在處理瞬時(shí)爆發(fā)性任務(wù)時(shí)會能用得到，例：

        Runnable precessImageRunner = new Runnable() {
            @Override
            public void run() {
                System.out.println("開始處理圖片了，我很耗時(shí)，，，，");
            }
        };
        List<Bitmap> bitmaps = new ArrayList<>();
        ExecutorService fixedExecutor = Executors.newFixedThreadPool(30);
        for (Bitmap bitmap : bitmaps) {
            fixedExecutor.execute(precessImageRunner);
        }
        fixedExecutor.shutdown();

fixedExecutor.shutdown() 來防止永遠(yuǎn)不回收造成資源浪費(fèi)的情況

Executor.newScheduledThreadPool()

創(chuàng)建一個(gè)延遲的線程池

Executor.newSingleThreadScheduledExecutor()

創(chuàng)建一個(gè)延遲的單線程線程池

總結(jié)

以上就是 Executor 的簡介及 Executor 五種創(chuàng)建線程的方式，你學(xué)廢了嗎？

復(fù)習(xí)一遍：

//  Executor 五種創(chuàng)建線程的方式
        Executors.newCachedThreadPool();
        Executors.newSingleThreadExecutor();
        Executors.newFixedThreadPool();
        Executors.newScheduledThreadPool();
        Executors.newSingleThreadScheduledExecutor();

到此這篇關(guān)于Java多線程實(shí)現(xiàn)之Executor詳解的文章就介紹到這了,更多相關(guān)Java多線程Executor內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: