線程池使用場景？

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

 Java線程池使用

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

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

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

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

又如：

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

通過newSingleThreadExecutor()方法可以獲得一個線程數(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()方法可以獲得一個根據(jù)需要創(chuàng)建線程的線程池，它會根據(jù)任務(wù)數(shù)創(chuàng)建對應(yīng)數(shù)量的線程。

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

1. corePoolSize：核心線程數(shù)
2. maximumPoolSize：最大線程數(shù)
3. keepAliveTime：空閑時間
4. unit：空閑時間單位
5. workQueue：任務(wù)隊列
6. threadFactory：創(chuàng)建線程的工廠
7. handler：飽和策略

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

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

總結(jié)

到此這篇關(guān)于Java線程池的簡單使用的文章就介紹到這了,更多相關(guān)Java線程池使用內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論