如何使用Java線程池

本篇內(nèi)容主要講解“如何使用Java線程池”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“如何使用Java線程池”吧!

目錄

• 線程池使用場景？

•  Java線程池使用

• 總結(jié)

線程池使用場景？

java中經(jīng)常需要用到多線程來處理一些業(yè)務(wù)，我們非常不建議單純使用繼承Thread或者實(shí)現(xiàn)Runnable接口的方式來創(chuàng)建線程，那樣勢必有創(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線程池使用

對于資源池的技術(shù)，相信大家早就接觸過，比如數(shù)據(jù)庫連接池，常見的有c3p0、dbcp等等，而線程也有對應(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)建對應(yīng)數(shù)量的線程。

我們發(fā)現(xiàn)，通過Executors類能夠創(chuàng)建各式各樣的線程池，但阿里巴巴Java開發(fā)手冊并不推薦我們使用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對象即可得到一個(gè)線程池，但需要指定七個(gè)參數(shù)，分別如下：

1. corePoolSize：核心線程數(shù)

2. maximumPoolSize：最大線程數(shù)

3. keepAliveTime：空閑時(shí)間

4. unit：空閑時(shí)間單位

5. workQueue：任務(wù)隊(duì)列

6. threadFactory：創(chuàng)建線程的工廠

7. handler：飽和策略

其中核心線程數(shù)表示線程池中最核心的線程，它們在任何情況下都不會(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è)簡單的例子，現(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ù)。

到此，相信大家對“如何使用Java線程池”有了更深的了解，不妨來實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！