本篇文章為大家展示了Java中的線程池類型有哪些，內容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。
一、線程池使用場景
單個任務處理時間短
將需處理的任務數量大
二、使用Java線程池好處
1、使用new Thread()創建線程的弊端：
•每次通過new Thread()創建對象性能不佳。
•線程缺乏統一管理，可能無限制新建線程，相互之間競爭，及可能占用過多系統資源導致死機或oom。
•缺乏更多功能，如定時執行、定期執行、線程中斷。
2、使用Java線程池的好處：
•重用存在的線程，減少對象創建、消亡的開銷，提升性能。
•可有效控制最大并發線程數，提高系統資源的使用率，同時避免過多資源競爭，避免堵塞。
•提供定時執行、定期執行、單線程、并發數控制等功能。
Java四種線程池
Java里面線程池的頂級接口是Executor，但是嚴格意義上講Executor并不是一個線程池，而只是一個執行線程的工具。真正的線程池接口是ExecutorService。下面這張圖完整描述了線程池的類體系結構：
1. newCachedThreadPool
創建一個可根據需要創建新線程的線程池，但是在以前構造的線程可用時將重用它們。對于執行很多短期異步任務的程序而言，這些線程池通?？商岣叱绦蛐阅?。調用 execute 將重用以前構造的線程（如果線程可用）。如果現有線程沒有可用的，則創建一個新線程并添加到池中。終止并從緩存中移除那些已有 60 秒鐘未被使用的線程。因此，長時間保持空閑的線程池不會使用任何資源。
public static ExecutorService newCachedThreadPool()
示例代碼：
public class ThreadPoolExecutorTest {
public static void main(String[] args ) {
ExecutorService cacheThreadPool =Executors.newCachedThreadPool();
for(int i =1;i<=5;i++){
final int index=i ;
try{
Thread.sleep(1000);
}catch(InterruptedException e ) {
e.printStackTrace();
}
cacheThreadPool.execute(new Runnable(){
@Override
public void run() {
System.out.println("第" +index +"個線程" +Thread.currentThread().getName());
}
});
}
}
}
//輸出結果
第1個線程pool-1-thread-1
第2個線程pool-1-thread-1
第3個線程pool-1-thread-1
第4個線程pool-1-thread-1 第5個線程pool-1-thread-1
由結果可看出 當執行第二個任務時第一個任務已經完成，會復用執行第一個任務的線程，而不用每次新建線程。
2. newFixedThreadPool
創建一個指定工作線程數量的線程池。每當提交一個任務就創建一個工作線程，如果工作線程數量達到線程池初始的最大數，則將提交的任務存入到池隊列中。
public static ExecutorService newFixedThreadPool(int nThreads)
nThreads - 池中的線程數
示例代碼：
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ExecutorService fixedThreadPool =Executors. newFixedThreadPool(3);
for (int i =1; i<=5;i++){
final int index=i ;
fixedThreadPool.execute(new Runnable(){
@Override
public void run() {
try {
System.out.println("第" +index + "個線程" +Thread.currentThread().getName());
Thread.sleep(1000);
} catch(InterruptedException e ) {
e .printStackTrace();
}
}
});
}
}
}由于設置最大線程數為3，所以在輸出三個數后等待2秒后才繼續輸出。
2. newScheduledThreadPool
創建一個線程池，它可安排在給定延遲后運行命令或者定期地執行。
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
corePoolSize - 池中所保存的線程數，即使線程是空閑的也包括在內。
延遲執行示例代碼：
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);
scheduledThreadPool.schedule(newRunnable(){
@Override
public void run() {
System.out.println("延遲三秒");
}
}, 3, TimeUnit.SECONDS);
}
}表示延遲3秒執行。
定期執行示例代碼：
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);
scheduledThreadPool.scheduleAtFixedRate(newRunnable(){
@Override
public void run() {
System.out.println("延遲1秒后每三秒執行一次");
}
},1,3,TimeUnit.SECONDS);
}
}表示延遲1秒后每3秒執行一次。
4.newSingleThreadExecutor
創建一個使用單個 worker 線程的 Executor，以無界隊列方式來運行該線程。（注意，如果因為在關閉前的執行期間出現失敗而終止了此單個線程，那么如果需要，一個新線程將代替它執行后續的任務）?？杀ＷC順序地執行各個任務，并且在任意給定的時間不會有多個線程是活動的。與其他等效的 newFixedThreadPool(1)不同，可保證無需重新配置此方法所返回的執行程序即可使用其他的線程。
public static ExecutorService newSingleThreadExecutor()
示例代碼：
public class ThreadPoolExecutorTest {
public static void main(String[] args) {
ExecutorService singleThreadPool= Executors.newSingleThreadExecutor();
for(int i=1;i<=5;i++){
int index=i;
singleThreadPool.execute(new Runnable(){
@Override
public void run() {
try{
System.out.println("第"+index+"個線程");
Thread.sleep(2000);
}catch(InterruptedException e) {
e.printStackTrace();
}
} });
}
}
}上述內容就是Java中的線程池類型有哪些，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
