如何使用Java線程池

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

目錄

• 線程池使用場景？

•  Java線程池使用

• 總結

線程池使用場景？

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

 Java線程池使用

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

Java提供了Executors類來創建一個線程池，如：

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

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

又如：

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

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

還有：

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

通過newCachedThreadPool()方法可以獲得一個根據需要創建線程的線程池，它會根據任務數創建對應數量的線程。

我們發現，通過Executors類能夠創建各式各樣的線程池，但阿里巴巴Java開發手冊并不推薦我們使用Executors類的方式創建線程，而是要自己手動創建：

那如何手動創建線程池呢？

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");
    });
}

構造ThreadPoolExecutor對象即可得到一個線程池，但需要指定七個參數，分別如下：

1. corePoolSize：核心線程數

2. maximumPoolSize：最大線程數

3. keepAliveTime：空閑時間

4. unit：空閑時間單位

5. workQueue：任務隊列

6. threadFactory：創建線程的工廠

7. handler：飽和策略

其中核心線程數表示線程池中最核心的線程，它們在任何情況下都不會被回收，而是等待任務的到來，最大線程數是線程池能夠創建的最大線程數，空閑時間表示某個非核心線程在等待空閑時間后仍然沒有任務執行，該線程便會被回收，創建線程的工廠用于指定創建線程的方式，一般默認即可，飽和策略表示當線程池達到最大線程數后，超出的任務應該如何進行處理。

舉一個簡單的例子，現在有10個任務等待執行，因為我們的核心線程數為5，所以線程池會先創建5個線程用于執行其中的5個任務，剩下的5個任務會被放入任務隊列，而任務隊列的容量只有3，所以任務隊列只能夠放下3個任務，剩下的2個任務無法放入隊列，線程池就會創建2個非核心線程用于執行它們，若是此時線程池中的線程數達到了最大線程數，則會觸發飽和策略，比如這里的CallerRunsPolicy策略，它將直接丟棄掉新的任務。

到此，相信大家對“如何使用Java線程池”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！