Java線程池的簡單使用方法實例教程

Posted on by

線程池使用場景？

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線程池的簡單使用的文章就介紹到這瞭,更多相關Java線程池使用內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：