快捷導(dǎo)航

Java線程池的簡(jiǎn)單使用方法實(shí)例教程

更新時(shí)間：2021年10月05日 11:24:30 作者：隨身電源

線程的使用在java中占有極其重要的地位,在jdk1.4極其之前的jdk版本中,關(guān)于線程池的使用是極其簡(jiǎn)陋的,在jdk1.5之后這一情況有了很大的改,這篇文章主要給大家介紹了關(guān)于Java線程池的簡(jiǎn)單使用方法,需要的朋友可以參考下

線程池使用場(chǎng)景？

java中經(jīng)常需要用到多線程來處理一些業(yè)務(wù)，我們非常不建議單純使用繼承Thread或者實(shí)現(xiàn)Runnable接口的方式來創(chuàng)建線程，那樣勢(shì)必有創(chuàng)建及銷毀線程耗費(fèi)資源、線程上下文切換問題。同時(shí)創(chuàng)建過多的線程也可能引發(fā)資源耗盡的風(fēng)險(xiǎn)，這個(gè)時(shí)候引入線程池比較合理，方便線程任務(wù)的管理。java中涉及到線程池的相關(guān)類均在jdk1.5開始的java.util.concurrent包中，涉及到的幾個(gè)核心類及接口包括：Executor、Executors、ExecutorService、ThreadPoolExecutor、FutureTask、Callable、Runnable等。

Java線程池使用

對(duì)于資源池的技術(shù)，相信大家早就接觸過，比如數(shù)據(jù)庫連接池，常見的有c3p0、dbcp等等，而線程也有對(duì)應(yīng)的池子，稱為線程池。

Java提供了Executors類來創(chuàng)建一個(gè)線程池，如：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(10);
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通過newFixedThreadPool()方法可以獲得一個(gè)指定線程數(shù)的線程池。

又如：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newSingleThreadExecutor();
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通過newSingleThreadExecutor()方法可以獲得一個(gè)線程數(shù)為1的線程池。

還有：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newCachedThreadPool();
    Thread thread = new Thread(() -> {
        System.out.println("hello world!");
    });
    executorService.execute(thread);
}

通過newCachedThreadPool()方法可以獲得一個(gè)根據(jù)需要?jiǎng)?chuàng)建線程的線程池，它會(huì)根據(jù)任務(wù)數(shù)創(chuàng)建對(duì)應(yīng)數(shù)量的線程。

我們發(fā)現(xiàn)，通過Executors類能夠創(chuàng)建各式各樣的線程池，但阿里巴巴Java開發(fā)手冊(cè)并不推薦我們使用Executors類的方式創(chuàng)建線程，而是要自己手動(dòng)創(chuàng)建：

那如何手動(dòng)創(chuàng)建線程池呢？

public static void main(String[] args) {
    ThreadPoolExecutor executor = new ThreadPoolExecutor(
            5,
            10,
            5L,
            TimeUnit.SECONDS,
            new ArrayBlockingQueue<>(3),
            Executors.defaultThreadFactory(),
            new ThreadPoolExecutor.CallerRunsPolicy());
    executor.execute(() -> {
        System.out.println("hello world");
    });
}

構(gòu)造ThreadPoolExecutor對(duì)象即可得到一個(gè)線程池，但需要指定七個(gè)參數(shù)，分別如下：

corePoolSize：核心線程數(shù)
maximumPoolSize：最大線程數(shù)
keepAliveTime：空閑時(shí)間
unit：空閑時(shí)間單位
workQueue：任務(wù)隊(duì)列
threadFactory：創(chuàng)建線程的工廠
handler：飽和策略

其中核心線程數(shù)表示線程池中最核心的線程，它們?cè)谌魏吻闆r下都不會(huì)被回收，而是等待任務(wù)的到來，最大線程數(shù)是線程池能夠創(chuàng)建的最大線程數(shù)，空閑時(shí)間表示某個(gè)非核心線程在等待空閑時(shí)間后仍然沒有任務(wù)執(zhí)行，該線程便會(huì)被回收，創(chuàng)建線程的工廠用于指定創(chuàng)建線程的方式，一般默認(rèn)即可，飽和策略表示當(dāng)線程池達(dá)到最大線程數(shù)后，超出的任務(wù)應(yīng)該如何進(jìn)行處理。

舉一個(gè)簡(jiǎn)單的例子，現(xiàn)在有10個(gè)任務(wù)等待執(zhí)行，因?yàn)槲覀兊暮诵木€程數(shù)為5，所以線程池會(huì)先創(chuàng)建5個(gè)線程用于執(zhí)行其中的5個(gè)任務(wù)，剩下的5個(gè)任務(wù)會(huì)被放入任務(wù)隊(duì)列，而任務(wù)隊(duì)列的容量只有3，所以任務(wù)隊(duì)列只能夠放下3個(gè)任務(wù)，剩下的2個(gè)任務(wù)無法放入隊(duì)列，線程池就會(huì)創(chuàng)建2個(gè)非核心線程用于執(zhí)行它們，若是此時(shí)線程池中的線程數(shù)達(dá)到了最大線程數(shù)，則會(huì)觸發(fā)飽和策略，比如這里的CallerRunsPolicy策略，它將直接丟棄掉新的任務(wù)。