更新時(shí)間:2023-04-14 來(lái)源:黑馬程序員 瀏覽量:
線程池中的線程是在線程池啟動(dòng)時(shí)就創(chuàng)建好的,而不是在任務(wù)到來(lái)時(shí)才動(dòng)態(tài)地創(chuàng)建線程。
線程池中的線程創(chuàng)建過(guò)程通常包括以下步驟:
1.初始化線程池參數(shù),例如線程池大小、核心線程數(shù)、最大線程數(shù)、等待隊(duì)列大小等。
2.創(chuàng)建線程池中的核心線程。核心線程在線程池中始終存在,除非線程池被關(guān)閉。
3.創(chuàng)建等待隊(duì)列。等待隊(duì)列是一個(gè)用于存儲(chǔ)任務(wù)的緩沖區(qū)域,當(dāng)線程池中的線程都在忙碌處理任務(wù)時(shí),新到來(lái)的任務(wù)將會(huì)被放入等待隊(duì)列中等待處理。
4.如果當(dāng)前任務(wù)數(shù)量超過(guò)了核心線程數(shù),那么線程池會(huì)創(chuàng)建新的線程來(lái)處理任務(wù),直到線程數(shù)達(dá)到最大線程數(shù)。
5.如果等待隊(duì)列已滿,且線程數(shù)已達(dá)到最大線程數(shù),那么線程池會(huì)根據(jù)定義的拒絕策略來(lái)拒絕新的任務(wù)。
下面是一個(gè)簡(jiǎn)單的示例代碼,展示了如何在Java中創(chuàng)建一個(gè)固定大小的線程池,線程池中的線程在初始化時(shí)就會(huì)被創(chuàng)建:
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class ThreadPoolExample { public static void main(String[] args) { // 創(chuàng)建一個(gè)固定大小的線程池,大小為3 ExecutorService executor = Executors.newFixedThreadPool(3); // 提交10個(gè)任務(wù)給線程池執(zhí)行 for (int i = 1; i <= 10; i++) { executor.execute(new Task(i)); } // 關(guān)閉線程池 executor.shutdown(); } static class Task implements Runnable { private int taskId; public Task(int taskId) { this.taskId = taskId; } public void run() { System.out.println("Task #" + taskId + " is being executed by " + Thread.currentThread().getName()); } } }
在上面的示例中,我們創(chuàng)建了一個(gè)固定大小的線程池,并提交了10個(gè)任務(wù)給線程池執(zhí)行。在每個(gè)任務(wù)執(zhí)行時(shí),都會(huì)輸出當(dāng)前任務(wù)的編號(hào)以及執(zhí)行任務(wù)的線程的名稱??梢钥吹?,每個(gè)任務(wù)都是由線程池中的一個(gè)線程來(lái)執(zhí)行的,而不是每次都創(chuàng)建一個(gè)新的線程。
總之,線程池中的線程是在啟動(dòng)時(shí)創(chuàng)建好的,并且會(huì)一直存在直到線程池被關(guān)閉。線程池的好處在于它可以重復(fù)使用已有的線程,避免了頻繁地創(chuàng)建和銷毀線程所帶來(lái)的開(kāi)銷和資源浪費(fèi)。