Java線程池使用淺談

来源:https://www.cnblogs.com/beyond-tester/archive/2023/12/19/17915096.html
-Advertisement-
Play Games

1. 線程池相關基本概念 任務（Task）：任務是線程池中要執行的工作單元。任務可以是實現了 Runnable 介面或 Callable 介面的對象。Runnable 任務沒有返回值，而 Callable 任務可以返回一個結果。 線程池管理器（ThreadPool Manager）：線程池管理器是用 ...


1. 線程池相關基本概念

  1. 任務（Task）：任務是線程池中要執行的工作單元。任務可以是實現了 Runnable 介面或 Callable 介面的對象。Runnable 任務沒有返回值，而 Callable 任務可以返回一個結果。

  2. 線程池管理器（ThreadPool Manager）：線程池管理器是用於創建和管理線程池的組件。它負責創建線程池，控制線程的創建和銷毀，並調度任務的執行。

  3. 工作線程（Worker Threads）：工作線程是線程池中實際執行任務的線程。線程池中可以有多個工作線程，它們並行地從任務隊列中獲取任務並執行。

  4. 任務隊列（Task Queue）：任務隊列是用於存儲待執行的任務的數據結構。當線程池中的工作線程空閑時，它們會從任務隊列中獲取任務並執行。

  5. 拒絕策略（Rejection Policy）：拒絕策略定義了當任務隊列已滿且無法繼續接收新的任務時，線程池應該如何處理新的任務。常見的拒絕策略包括丟棄任務、丟棄最早的任務、拋出異常等。

  6. 線程池大小（Pool Size）：線程池大小指定了線程池中工作線程的數量。線程池的大小可以是固定的，也可以是根據需要自動調整的。

  7. 核心線程數（Core Pool Size）：核心線程數是線程池中保持活動狀態的最小工作線程數量。即使線程處於空閑狀態，核心線程也不會被銷毀。

  8. 最大線程數（Maximum Pool Size）：最大線程數是線程池中允許的最大工作線程數量。當任務隊列已滿且活動線程數達到最大線程數時，線程池可能會創建新的線程來執行任務。

  9. 閑置線程回收時間（Keep-Alive Time）：閑置線程回收時間是指當線程池中的線程數超過核心線程數，並且空閑一段時間後，多餘的線程會被銷毀。

  10. 線程工廠（Thread Factory）：線程工廠用於創建線程池中的工作線程。它負責創建線程，並可以自定義線程的屬性和命名方式。

線程池的設計目的是提高系統的性能和資源利用率。通過重用線程和控制併發線程的數量，線程池可以減少線程創建和銷毀的開銷，避免資源耗盡，並提供更好的任務調度和執行控制。

在使用線程池時，我們可以根據任務的類型和系統的需求來選擇適當的線程池大小、拒絕策略和其他參數，以實現最佳的性能和可擴展性。

2. 線程池主要處理流程

  • 判斷核心線程池是否已滿，如果不是，則創建線程執行任務
  • 如果核心線程池滿了，判斷隊列是否滿了，如果隊列沒滿，將任務放在隊列中
  • 如果隊列滿了，則判斷線程池是否已滿，如果沒滿，創建線程執行任務
  • 如果線程池也滿了，則按照拒絕策略對任務進行處理

更進一步的裡層核心類處理流程：

當我們使用 Java 中的 ThreadPoolExecutor 類來創建線程池時，其處理流程如下：

  1. 任務提交：外部調用者通過調用 ThreadPoolExecutor 的 execute() 或 submit() 方法將任務提交給線程池。

  2. 任務接收：ThreadPoolExecutor 接收到任務後，首先檢查線程池的狀態。如果線程池已經關閉，就不再接收新的任務。

  3. 任務排隊：線程池將接收到的任務放入內部的任務隊列中等待執行。任務隊列可以是有界隊列（如 ArrayBlockingQueue）或無界隊列（如 LinkedBlockingQueue 或 SynchronousQueue）。

  4. 工作線程獲取任務：線程池中的工作線程從任務隊列中獲取任務。如果任務隊列為空，工作線程可能會阻塞等待新任務的到來，或者在等待一定時間後退出。

  5. 任務執行：工作線程獲取到任務後，調用任務對象的 run() 方法執行任務的具體邏輯。

  6. 任務完成：任務執行完成後，可以返回一個結果（對於 Callable 任務），或者不返回任何結果（對於 Runnable 任務）。

  7. 任務狀態更新：ThreadPoolExecutor 會更新任務的狀態，包括任務的執行進度、執行結果等信息。

  8. 結果返回：如果任務是 Callable 任務，ThreadPoolExecutor 會將任務的執行結果封裝在 Future 對象中返回給調用者。調用者可以通過 Future 對象獲取任務的執行結果。

  9. 繼續處理下一個任務：工作線程完成當前任務後，會繼續從任務隊列中獲取下一個任務進行處理。

  10. 線程回收：如果線程池中的線程處於空閑狀態，並且空閑時間超過一定閾值，ThreadPoolExecutor 可能會回收這些空閑線程，以避免資源的浪費。

  11. 異常處理：ThreadPoolExecutor 會捕獲任務執行過程中的異常，並根據預定義的異常處理策略進行處理，比如記錄日誌、統計異常次數等。

  12. 線程池關閉：當不再需要線程池時，調用 ThreadPoolExecutor 的 shutdown() 或 shutdownNow() 方法來停止線程池的運行。關閉線程池的過程包括不再接收新任務、等待已提交的任務執行完成、銷毀工作線程等操作。

ThreadPoolExecutor 是 Java 中用於創建和管理線程池的核心類，通過其靈活的配置參數，可以實現對線程池的各種行為和特性進行定製。這個類提供了豐富的方法和選項，用於控制線程池的大小、任務隊列類型、拒絕策略、線程工廠等，以滿足不同場景下的需求。

3. 線程池實現的主要步驟

3.1 創建線程池

在 Java 中，可以使用 Executors 類提供的靜態方法創建線程池。以下是幾種常見的創建線程池的方法：

3.1.1 創建固定大小的線程池

固定大小的線程池將在初始化時創建指定數量的線程，並且不會增加或減少線程的數量。

ExecutorService executorService = Executors.newFixedThreadPool(10);//創建一個固定大小為 10 的線程池
3.1.2 創建單個線程的線程池

單個線程的線程池只會創建一個工作線程來執行任務。

ExecutorService executorService = Executors.newSingleThreadExecutor();
3.1.3 創建可根據需要自動調整大小的線程池

可根據需要自動調整大小的線程池將根據任務的數量動態地增加或減少線程的數量。

ExecutorService executorService = Executors.newCachedThreadPool();
3.1.4 手動按自己需求創建線程池

在 Java 中，可以手動創建線程池，而不僅僅依賴於內置的線程池實現。手動創建線程池的主要原因是為了更好地控制線程池的行為、特性和參數配置，以滿足特定的需求，比如特定的任務隊列類型需求，特定的拒絕策略需求

根據ThreadPoolExecutor構造方法可知，需要準備以下參數：

  1. 核心線程數（corePoolSize）：核心線程數是線程池中保持活動狀態的線程數。即使這些線程處於空閑狀態，它們也不會被回收。線程池會根據任務的數量和任務隊列的狀態來動態調整線程池中的線程數量。

  2. 最大線程數（maximumPoolSize）：最大線程數指定了線程池中允許存在的最大線程數量。當任務數量超過核心線程數並且任務隊列已滿時，線程池會創建新的線程來處理任務，直到達到最大線程數。如果達到最大線程數後仍有任務到來，採用拒絕策略處理新任務。

  3. 空閑線程存活時間（keepAliveTime）：當線程池中的線程數超過核心線程數，並且處於空閑狀態時，空閑線程存活時間指定了它們在沒有接收到新任務時的存活時間。超過存活時間後，空閑線程將被回收，直到線程池中的線程數不超過核心線程數。

  4. 時間單位（unit）：用於指定時間參數的單位，可以是秒、毫秒、微秒等。

  5. 任務隊列（workQueue）：任務隊列用於存儲等待執行的任務。可以選擇合適的隊列類型，如有界隊列（如 ArrayBlockingQueue）或無界隊列（如 LinkedBlockingQueue）。

  6. 線程工廠（threadFactory）：線程工廠用於創建線程對象。可以自定義線程工廠類，實現創建線程的邏輯。

  7. 拒絕策略（rejectedExecutionHandler）：當任務隊列已滿並且線程池中的線程數達到最大線程數時，拒絕策略指定瞭如何處理新的任務。可以選擇預定義的拒絕策略，如拋出異常、丟棄任務等，或者自定義拒絕策略。

import java.util.concurrent.*;

// 自定義拒絕策略類
class CustomRejectedExecutionHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable runnable, ThreadPoolExecutor executor) {
        // 自定義拒絕策略的邏輯
        System.out.println("Task Rejected: " + runnable.toString());
        // 可根據需求進行不同的處理方式，如拋出異常、丟棄任務、調用者執行等
    }
}

// 自定義線程工廠類
class CustomThreadFactory implements ThreadFactory {
    @Override
    public Thread newThread(Runnable runnable) {
        // 自定義線程工廠的邏輯
        Thread thread = new Thread(runnable);
        // 可以進行一些線程屬性的配置，如設置線程名稱、優先順序等
        thread.setName("CustomThread");
        thread.setPriority(Thread.NORM_PRIORITY);
        return thread;
    }
}

public class ManualThreadPoolCreationExample {
    public static void main(String[] args) {
        // 創建自定義的拒絕策略實例
        RejectedExecutionHandler rejectionHandler = new CustomRejectedExecutionHandler();

        // 創建自定義的線程工廠實例
        ThreadFactory threadFactory = new CustomThreadFactory();

        // 創建任務隊列（這裡使用無界隊列）
        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();

        // 創建線程池併進行手動配置
        int corePoolSize = 10;
        int maxPoolSize = 20;
        long keepAliveTime = 60;
        TimeUnit timeUnit = TimeUnit.SECONDS;
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
                corePoolSize,
                maxPoolSize,
                keepAliveTime,
                timeUnit,
                workQueue,
                threadFactory,
                rejectionHandler
        );
    }
}

3.2 提交任務給線程池執行

創建線程池之後，可以將任務提交給線程池執行。任務可以是實現了 Runnable 介面的對象，也可以是實現了 Callable 介面的對象。

3.2.1  提交 Runnable 任務

executorService.execute(new Runnable() {
    @Override
    public void run() {
        // 任務邏輯
    }
});

或者使用 Lambda 表達式：

executorService.execute(() -> {
    // 任務邏輯
});

3.2.2 提交 Callable 任務

Callable 任務可以返回一個結果

Future<SomeResult> future = executorService.submit(new Callable<SomeResult>() {
    @Override
    public SomeResult call() throws Exception {
        // 任務邏輯
        return someResult;
    }
});

或者使用 Lambda 表達式：


Future<SomeResult> future = executorService.submit(() -> {
    // 任務邏輯
    return someResult;
});

3.3 關閉線程池

當不再需要線程池時，應該顯式地關閉它，以釋放資源。關閉線程池兩種方式

executorService.shutdown(); // 不再接受新的任務，但會等待已提交的任務執行完成。

executorService.shutdownNow(); //希望立即關閉線程池，並嘗試中斷正在執行的任務

3.4 處理任務執行結果

當提交任務給線程池執行後，可以通過 Future 對象來獲取任務的執行結果。

Future<SomeResult> future = executorService.submit(...);

try {
    SomeResult result = future.get();
    // 處理結果
} catch (InterruptedException e) {
    // 處理中斷異常
} catch (ExecutionException e) {
    // 處理執行異常
}

使用 future.get() 方法可以阻塞當前線程，直到任務執行完成並返回結果。get() 方法可能會拋出 InterruptedException 和 ExecutionException 異常，需要進行適當的異常處理。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Linux伺服器快速安裝FastGPT知識庫問答系統
    最近開始體驗FastGPT知識庫問答系統，參考官方文檔，在自己的阿裡雲伺服器使用Docker Compose快速完成了部署。 環境說明：阿裡雲ECS，2核8G，X86架構，CentOS 7.9操作系統。 Docker與Docker-Compose安裝 1.登錄伺服器，執行相關命令完成安裝。 # 安裝 ...
  • 記錄--一行代碼修複100vh bug
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 你知道奇怪的移動視口錯誤（也稱為100vh bug）嗎？或者如何以正確的方式創建全屏塊？ 一、100vh bug 什麼是移動視口錯誤？ 你是否曾經在網頁上創建過全屏元素？只需添加一行 CSS 並不難： .my-page { height: ...
  • qiankun 微前端實例化使用
    一、qiankun使用場景 1. 簡介：qiankun是在single-spa的基礎上實現的，可以保證各個項目獨立使用，也可以集成使用。各系統之間不受技術棧的限制，集成使用也能保證各樣式和全局變數的隔離。 模塊的插拔式使用，當公司項目集是一個大系統下包含多個子系統或者模塊時，可以採用這種方式動態部署 ...
  • 一行代碼修複100vh bug | 京東雲技術團隊
    你知道奇怪的移動視口錯誤（也稱為100vh bug）嗎？或者如何以正確的方式創建全屏塊？ 一、100vh bug 什麼是移動視口錯誤？ 你是否曾經在網頁上創建過全屏元素？只需添加一行 CSS 並不難： .my-page { height: 100vh } 1vh是視口高度的1% ，正是我們所需要的。 ...
  • Chrome擴展開發系列開篇
    基於 Chromium 的瀏覽器占了全球市場的 7 成！對於前端開發來說，Chrome 更是形影不離的飯碗級軟體
  • 【UniApp】-uni-app-pinia存儲數據
    前言 經過上個章節的介紹，大家可以瞭解到 uni-app-數據緩存 的基本使用方法 那本章節來給大家介紹一下 uni-app-pinia存儲數據 的基本使用方法 經過我這麼多篇章的介紹，我發現大家環境比較耗時，所以在今後的文章中，我會儘量減少環境的搭建 如果某一篇的文章環境確實是不一樣的，我會在文章 ...
  • 讀程式員的README筆記16_構建可演進的架構（上）
    1. 行為準則 2. 需求的不確定性 2.1. 不斷變化的客戶需求 2.2. 軟體項目無法避免的挑戰 2.3. 產品需求和環境會隨著時間的推移而改變，你的應用程式也必須隨之改變 2.4. 不斷變化的需求會導致不穩定性，使開發工作偏離軌道 2.5. 通過構建可演進的架構來適應不斷變化的需求 2.5.1 ...
  • 3、SpringBoot2之配置文件
    3.1、環境搭建 3.1.1、在project創建新module 3.1.2、選擇maven 3.1.3、設置module名稱和路徑 3.1.4、module初始狀態 3.1.5、引入springboot父工程 <parent> <groupId>org.springframework.boot</ ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類