實現簡單線程池

来源:https://www.cnblogs.com/daihang2366/archive/2023/09/23/17724423.html
-Advertisement-
Play Games

實現基本的線程池 前提:我們要實現的線程池有如下功能: 基本的線程池模型 能提交和運行任務 能正常關閉線程池 線程的拒絕策略 線程池擴容 縮容線程池 代碼地址: 1、線程池的介紹? 線程池是什麼? 線程池是一種利用池化技術來管理線程的一種技術。 當沒有線程池的時候,我們如何創建線程? 繼承Threa ...


實現基本的線程池

前提:我們要實現的線程池有如下功能:

  1. 基本的線程池模型
  2. 能提交和運行任務
  3. 能正常關閉線程池
  4. 線程的拒絕策略
  5. 線程池擴容
  6. 縮容線程池

代碼地址:

1、線程池的介紹?

線程池是什麼?

線程池是一種利用池化技術來管理線程的一種技術。

當沒有線程池的時候,我們如何創建線程?

  1. 繼承Thread
  2. 實現Runnable介面
  3. 使用Callable和Future來創建線程

當我們自己創建線程時,使用線程的步驟是什麼?之間有什麼問題?

使用線程的步驟:

  1. 創建線程
  2. 啟動線程
  3. 執行業務
  4. 關閉線程

在上述的四步中,我們發現如下幾個問題:

  1. 其實只有第三步是我們關鍵的步驟,其他三步都是為了使用線程本身去執行,使用線程繁瑣。
  2. 每次使用完線程後都需要關閉線程,而開闢線程本身是很耗費資源的,此時就會造成資源浪費。

而線程池的作用就是簡化線程的使用,優化資源的利用。下麵就開始實現線程池

2、實現線程池

在實現線程池的過程中,我們分幾個步驟來實現,先實現線程池的最基本的功能,再一步一步去完善其功能。

2.1、線程池雛形

本章節實現線程池的基本雛形。那麼線程池的雛形包括了:

  1. 定義一個隊列用於存儲當前待執行的任務
  2. 定義一個集合用於放置執行任務的多個線程
  3. 提供一個方法供用戶提交任務
  4. 自定義一個線程用於執行用戶提交的任務
  5. 提供工廠供用戶獲取線程池

2.2、線程池的關閉

如果不實現關閉線程池的功能,那麼在JVM停止運行時,線程池中的線程仍處於運行狀態,這會導致JVM無法停止。

那麼在實現關閉線程池功能前,我們先對線程池內的線程設定幾個狀態:

BLOCK:等待執行任務
RUNNING:正在執行任務中
STOP:線程已經關閉

對線程池本身設定幾個狀態:

STARED:線程池正常運行中
STOP:線程池已經關閉

然後在不同的情況下對不同的狀態進行更改、】校驗

2.3、拒絕策略

2.1、為什麼存在拒絕策略?

​ 線程池在接收任務的時候,如果某些任務正在執行,而新接收的任務無法立即得到執行時,新接收的任務就需要等待線程去運行。在這個過程中,等待運行的任務如果不加以限制,則會導致等待的任務無法增大。

​ 而線上程池中對等待執行任務(隊列)的數量限制策略被稱之為拒絕策略。

​ 例如假設我們限定隊列最大為100,那麼在隊列達到100以後,再提交任務時,有的策略規定當前提交任務的操作阻塞等待隊列有空位,亦或者直接返回錯誤。

2.2、如何實現?

​ 我們需要給隊列設置一個大小臨界值,當到達這個臨界值以後,執行相對應的拒絕策略實現即可。

2.4、線程池的擴容和縮容

為什麼線程池需要擴容?如何實現

​ 一個線程池是需要能夠動態伸縮的,例如初始化時線程池中線程數為5個,那麼在任務繁重的時候,為了更快的將任務執行完成,可以臨時增加線程,已達到加快任務執行的目的,這個操作被稱之為線程池的擴容。

​ 而當繁重的任務處理完後,臨時增加出來的線程會一直空閑,如果此時不將其釋放,則會浪費多餘的線程資源,而將多餘的線程資源釋放的操作被稱之為線程池的縮容。

​ 實現線程池擴/縮容之前,先要定義幾個變數:

​ 核心線程數:coreThread,保證線程池中最小常駐線程數

​ 最大線程數:maxThread,線程池中線程最大可以擴容到當前數量

​ 實現邏輯:

​ 1、當隊列數量大於核心線程數時即可將線程數擴容至maxThread

​ 2、當隊列裡面沒有任務時,即可將線程數縮容至coreThread

附:完整源碼

https://gitee.com/kxsdh/simple-thread-pool


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

-Advertisement-
Play Games
更多相關文章
  • 搭建後臺管理系統模板 2.1項目初始化 今天來帶大家從0開始搭建一個vue3版本的後臺管理系統。一個項目要有統一的規範,需要使用eslint+stylelint+prettier來對我們的代碼質量做檢測和修複,需要使用husky來做commit攔截,需要使用commitlint來統一提交規範,需要使 ...
  • Uber公司技術棧介紹 Uber(Uber Technologies,Inc.)中文譯作“優步”,是一家美國矽谷的科技公司。Uber在2009年,由加利福尼亞大學洛杉磯分校輟學生特拉維斯·卡蘭尼克和好友加勒特·坎普(Garrett Camp)創立。因旗下同名打車APP而名聲大噪。Uber已經進入中國 ...
  • 1. 定義通用返回結果類 ​ 定義ResultVO類,作返回給前端的對象結構,主要有4個欄位 code : 錯誤碼 data : 內容 message : 消息 description : 具體描述 import lombok.Data; import java.io.Serializable; / ...
  • 接上篇,當我們創建了很多類,比如 圖書館里的藏書,分社會科學類,藝術類、生活類、農業類、工業類等,而工業類又分為輕工業、重工業、信息工業,然後再細分。當分的越來越細時,程式就會越來越大。如何管理,便成了程式開發過程中一個重要的環節。於是可以按照圖書館分類管理的思想,對程式代碼進行管理。 將一個應用程 ...
  • Ribbon 簡介 Ribbon 是 Netfix 客戶端的負載均衡器,可對 HTTP 和 TCP 客戶端的行為進行控制。為 Ribbon 配置服務提供者地址後,Ribbon 就可以基於某種負載均衡演算法自動幫助服務消費者去請求。Ribbon 預設提供了很多負載均衡演算法,例如輪詢、隨機等,也可以為 R ...
  • 編譯nw-node版本的插件 下載nwjs對應版本的nodejs 原始源碼目錄 yh@yh:~/addon$ tree . ├── addon.cc ├── binding.gyp ├── CppLib │ ├── mynumber.cpp │ └── mynumber.h ├── myobject ...
  • 歡迎訪問我的GitHub 這裡分類和彙總了欣宸的全部原創(含配套源碼):https://github.com/zq2599/blog_demos 本篇概覽 欣宸正在為接下新的Java雲原生實戰系列原創做準備,既然是實戰,少不了一套雲原生環境,以下內容是必不可少的: linux操作系統 kuberne ...
  • SDRAM基本信息 儲存能力計算 4X16X4=256(Mbit),註意不是MByte SDRAM控制 sdram包含兩個部分:sdram_ctrl、fifo_ctrl。 sdram_ctrl:其頂層為SDRAM的控制模塊內部實例化了5個模塊,有初始化、自刷新、寫和讀模塊,還有一個仲裁模塊對這四個不 ...
一周排行
    -Advertisement-
    Play Games
  • 當使用Autofac處理一個介面有多個實現的情況時,通常會使用鍵(key)進行區分或者通過IIndex索引註入,也可以通過IEnumerable集合獲取所有實例,以下是一個具體的例子,演示如何在Autofac中註冊多個實現,並通過構造函數註入獲取指定實現。 首先,確保你已經安裝了Autofac Nu ...
  • 本篇將分享Prometheus+Grafana的監控平臺搭建,並監控之前文章所搭建的主機&服務,分享日常使用的一些使用經驗本篇將配置常用服務的監控與面板配置:包括 MySQL,MongoDB,CLickHouse,Redis,RabbitMQ,Linux,Windows,Nginx,站點訪問監控,已... ...
  • 使用Aspirate可以將Aspire程式部署到Kubernetes 集群 工具安裝 dotnet tool install -g aspirate --prerelease 註意:Aspirate 正在開發中,該軟體包將作為預覽版進行版本控制,--prelease 選項將獲得最新的預覽版。 容器註 ...
  • 前言 本文要說的這種開發模式,這種模式並不是只有blazor支持,js中有一樣的方案next.js nuxt.js;blazor還有很多其它內容,本文近關註漸進式開發模式。 是的,前後端是主流,不過以下情況也許前後端分離並不是最好的選擇: 小公司,人員不多,利潤不高,創業階段能省則省 個人開發者,接 ...
  • 在.NET中,Microsoft.Extensions.Logging是一個靈活的日誌庫,它允許你將日誌信息記錄到各種不同的目標,包括資料庫。在這個示例中,我將詳細介紹如何使用Microsoft.Extensions.Logging將日誌保存到MySQL資料庫。我們將使用Entity Framewo ...
  • chatgpt介面開發筆記3: 語音識別介面 1.文本轉語音 1、瞭解介面參數 介面地址: POST https://api.openai.com/v1/audio/speech 下麵是介面文檔描述內容: 參數: { "model": "tts-1", "input": "你好,我是饒坤,我是ter ...
  • 前面兩篇文章主要是介紹瞭如何解決高併發情況下資源爭奪的問題。但是現實的應用場景中除了要解決資源爭奪問題,高併發的情況還需要解決更多問題,比如快速處理業務數據等, 本篇文章簡要羅列一下與之相關的更多技術細節。 1、非同步編程:使用async和await關鍵字進行非同步編程,這可以避免阻塞線程,提高程式的響 ...
  • 大家好,我是棧長。 Nacos 2.3.0 前幾天正式發佈了,新增了不少實用性的新功能,真是史上最強版本。 Nacos 2.3.0 還真是一個比較重要的大版本,因為它涉及了太多重大更新,今天棧長給大家來解讀下。 Nacos 先掃個盲: Nacos 一個用於構建雲原生應用的動態服務發現、配置管理和服務 ...
  • IDEA的遠程開發功能,可以將本地的編譯、構建、調試、運行等工作都放在遠程伺服器上執行,而本地僅運行客戶端軟體進行常規的開發操作即可,舊版本IDEA目前不支持該功能.,本例使用的是IDEA2023.2.5版本 下麵介紹如何在IDEA中設置遠程連接伺服器開發環境並結合Cpolar內網穿透工具實現無公網 ...
  • 本文解釋為啥會有響應式編程,為什麼它在開發者中不太受歡迎,以及引入 Java 虛擬線程後它可能最終會消失。 命令式風格編程一直深受開發者喜愛,如 if-then-else、while 迴圈、函數和代碼塊等結構使代碼易理解、調試,異常易追蹤。然而,像所有好的東西一樣,通常也有問題。這種編程風格導致線程 ...