文章目錄

• 前言
• 一、線程池示例
• 二、newCachedThreadPool 線程池示例
• 三、newFixedThreadPool 線程池示例
• 三、newSingleThreadExecutor 線程池示例

前言

在上一篇博客 【Java 并發編程】線程池機制 ( 測試線程開銷 | 啟動線程分析 | 用戶態 | 內核態 | 用戶線程 | 內核線程 | 輕量級進程 ) 中 , 分析了線程的開銷 ;

本篇博客中使用線程池改造該示例并進行分析 ;

一、線程池示例

---

創建 $10$ 萬線程 , 需要 $10992$ ms ; 使用線程池啟動 $10$ 萬線程 , 僅需要 $26$ ms ;

線程池的效率比線程高幾個數量級 ;

線程池示例 :

import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class Main {/*** 線程中對該值進行累加操作*/private static int count = 0;public static void main(String[] args) throws InterruptedException {// 記錄程序開始執行時間long startTime = System.currentTimeMillis();// 線程池ExecutorService executorService = Executors.newSingleThreadExecutor();// 每次線程執行完畢, 計數 -1 , 當計數減到 0 之后, 才能解除阻塞CountDownLatch countDownLatch = new CountDownLatch(100000);// 創建 10 萬個線程, 開啟線程后, 向集合中添加一個元素for (int i = 0; i < 100000; i ++) {executorService.execute(new Runnable() {@Overridepublic void run() {count ++;// 計數 -1countDownLatch.countDown();}});}// 阻塞等待計數 -1, 直到 10000 個線程執行完畢// 使用這種方式確定所有線程執行完畢countDownLatch.await();// 執行完畢后, 停掉線程池, 否則程序不會退出executorService.shutdown();// 記錄程序執行結束時間long endTime = System.currentTimeMillis();// 打印消耗的時間System.out.println("耗時 : " + ( endTime - startTime ) + " ms , 最終 count = " + count);} }

執行結果 : 原來使用線程需要 $10992$ ms 時間 , 使用線程池后 , 僅需要 $26$ ms , 這效率提升了好幾個數量級 ;

等待線程執行結束 , 直接調用 Thread.join() 方法 , 等待線程池結束 , 借助 CountDownLatch 通過線程計數來確定線程是否執行完畢 ;

調用 ExecutorService executorService = Executors.newSingleThreadExecutor() 創建線程池 , 創建的是 FinalizableDelegatedExecutorService 線程池 ;

public static ExecutorService newSingleThreadExecutor() {return new FinalizableDelegatedExecutorService(new ThreadPoolExecutor(1, 1,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>()));}

二、newCachedThreadPool 線程池示例

---

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService1 = Executors.newCachedThreadPool();for (int i = 0; i < 100; i ++) {executorService1.execute(new Task(i));}}static class Task implements Runnable {/*** 記錄線程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("線程 ID : " + Thread.currentThread().getName() + " , 線程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} }

執行結果 : 該線程池中創建了 $100$ 個線程 , 執行 $100$ 個任務 ;

三、newFixedThreadPool 線程池示例

---

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService2 = Executors.newFixedThreadPool(10);for (int i = 0; i < 100; i ++) {executorService2.execute(new Task(i));}}static class Task implements Runnable {/*** 記錄線程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("線程 ID : " + Thread.currentThread().getName() + " , 線程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} }

執行結果 : 該線程池中創建了 $10$ 個線程 , 執行 $100$ 個任務 ;

三、newSingleThreadExecutor 線程池示例

---

import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executorService3 = Executors.newSingleThreadExecutor();for (int i = 0; i < 100; i ++) {executorService3.execute(new Task(i));}}static class Task implements Runnable {/*** 記錄線程的索引 0 ~ 99*/private int i = 0;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println("線程 ID : " + Thread.currentThread().getName() + " , 線程索引 : " + i);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} }

執行結果 : 該線程池中創建了 $1$ 個線程 , 執行 $100$ 個任務 ;

總結

以上是生活随笔為你收集整理的【Java 并发编程】线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。