色哟哟视频在线观看-色哟哟视频在线-色哟哟欧美15最新在线-色哟哟免费在线观看-国产l精品国产亚洲区在线观看-国产l精品国产亚洲区久久

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
电子发烧友
开通电子发烧友VIP会员 尊享10大特权
海量资料免费下载
精品直播免费看
优质内容免费畅学
课程9折专享价
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

如何正確使用SpringBoot中的線程池

Android編程精選 ? 來源:CSDN博客 ? 作者:如漩渦 ? 2021-09-02 17:14 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

來自丨CSDN

https://blog.csdn.net/m0_37701381/article/details/81072774

使用步驟

先創建一個線程池的配置,讓Spring Boot加載,用來定義如何創建一個ThreadPoolTaskExecutor,要使用@Configuration和@EnableAsync這兩個注解,表示這是個配置類,并且是線程池的配置類

@Configuration@EnableAsyncpublic class ExecutorConfig {

private static final Logger logger = LoggerFactory.getLogger(ExecutorConfig.class);

@Value(“${async.executor.thread.core_pool_size}”)

private int corePoolSize;

@Value(“${async.executor.thread.max_pool_size}”)

private int maxPoolSize;

@Value(“${async.executor.thread.queue_capacity}”)

private int queueCapacity;

@Value(“${async.executor.thread.name.prefix}”)

private String namePrefix;

@Bean(name = “asyncServiceExecutor”)

public Executor asyncServiceExecutor() {

logger.info(“start asyncServiceExecutor”);

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

//配置核心線程數

executor.setCorePoolSize(corePoolSize);

//配置最大線程數

executor.setMaxPoolSize(maxPoolSize);

//配置隊列大小

executor.setQueueCapacity(queueCapacity);

//配置線程池中的線程的名稱前綴

executor.setThreadNamePrefix(namePrefix);

// rejection-policy:當pool已經達到max size的時候,如何處理新任務

// CALLER_RUNS:不在新線程中執行任務,而是有調用者所在的線程來執行

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

//執行初始化

executor.initialize();

return executor;

}

}

@Value是我配置在application.properties,可以參考配置,自由定義

# 異步線程配置# 配置核心線程數

async.executor.thread.core_pool_size = 5

# 配置最大線程數

async.executor.thread.max_pool_size = 5

# 配置隊列大小

async.executor.thread.queue_capacity = 99999

# 配置線程池中的線程的名稱前綴

async.executor.thread.name.prefix = async-service-

創建一個Service接口,是異步線程的接口

public interface AsyncService {

/**

* 執行異步任務

* 可以根據需求,自己加參數擬定,我這里就做個測試演示

*/

void executeAsync();

}

實現類

@Servicepublic class AsyncServiceImpl implements AsyncService {

private static final Logger logger = LoggerFactory.getLogger(AsyncServiceImpl.class);

@Override

@Async(“asyncServiceExecutor”)

public void executeAsync() {

logger.info(“start executeAsync”);

System.out.println(“異步線程要做的事情”);

System.out.println(“可以在這里執行批量插入等耗時的事情”);

logger.info(“end executeAsync”);

}

}

將Service層的服務異步化,在executeAsync()方法上增加注解@Async(“asyncServiceExecutor”),asyncServiceExecutor方法是前面ExecutorConfig.java中的方法名,表明executeAsync方法進入的線程池是asyncServiceExecutor方法創建的。

接下來就是在Controller里或者是哪里通過注解@Autowired注入這個Service

@Autowiredprivate AsyncService asyncService;

@GetMapping(“/async”)

public void async(){

asyncService.executeAsync();

}

用postmain或者其他工具來多次測試請求一下

2018-07-16 2247.655 INFO 10516 --- [async-service-5] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2247.655 INFO 10516 --- [async-service-5] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2247.770 INFO 10516 --- [async-service-1] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2247.770 INFO 10516 --- [async-service-1] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2247.816 INFO 10516 --- [async-service-2] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2247.816 INFO 10516 --- [async-service-2] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2248.833 INFO 10516 --- [async-service-3] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2248.834 INFO 10516 --- [async-service-3] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2248.986 INFO 10516 --- [async-service-4] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2248.987 INFO 10516 --- [async-service-4] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

通過以上日志可以發現,[async-service-]是有多個線程的,顯然已經在我們配置的線程池中執行了,并且每次請求中,controller的起始和結束日志都是連續打印的,表明每次請求都快速響應了,而耗時的操作都留給線程池中的線程去異步執行;

雖然我們已經用上了線程池,但是還不清楚線程池當時的情況,有多少線程在執行,多少在隊列中等待呢?這里我創建了一個ThreadPoolTaskExecutor的子類,在每次提交線程的時候都會將當前線程池的運行狀況打印出來

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import org.springframework.util.concurrent.ListenableFuture;

import java.util.concurrent.Callable;

import java.util.concurrent.Future;

import java.util.concurrent.ThreadPoolExecutor;

/**

* @Author: ChenBin

*/public class VisiableThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {

private static final Logger logger = LoggerFactory.getLogger(VisiableThreadPoolTaskExecutor.class);

private void showThreadPoolInfo(String prefix) {

ThreadPoolExecutor threadPoolExecutor = getThreadPoolExecutor();

if (null == threadPoolExecutor) {

return;

}

logger.info(“{}, {},taskCount [{}], completedTaskCount [{}], activeCount [{}], queueSize [{}]”,

this.getThreadNamePrefix(),

prefix,

threadPoolExecutor.getTaskCount(),

threadPoolExecutor.getCompletedTaskCount(),

threadPoolExecutor.getActiveCount(),

threadPoolExecutor.getQueue().size());

}

@Override

public void execute(Runnable task) {

showThreadPoolInfo(“1. do execute”);

super.execute(task);

}

@Override

public void execute(Runnable task, long startTimeout) {

showThreadPoolInfo(“2. do execute”);

super.execute(task, startTimeout);

}

@Override

public Future《?》 submit(Runnable task) {

showThreadPoolInfo(“1. do submit”);

return super.submit(task);

}

@Override

public 《T》 Future《T》 submit(Callable《T》 task) {

showThreadPoolInfo(“2. do submit”);

return super.submit(task);

}

@Override

public ListenableFuture《?》 submitListenable(Runnable task) {

showThreadPoolInfo(“1. do submitListenable”);

return super.submitListenable(task);

}

@Override

public 《T》 ListenableFuture《T》 submitListenable(Callable《T》 task) {

showThreadPoolInfo(“2. do submitListenable”);

return super.submitListenable(task);

}

}

如上所示,showThreadPoolInfo方法中將任務總數、已完成數、活躍線程數,隊列大小都打印出來了,然后Override了父類的execute、submit等方法,在里面調用showThreadPoolInfo方法,這樣每次有任務被提交到線程池的時候,都會將當前線程池的基本情況打印到日志中;

修改ExecutorConfig.java的asyncServiceExecutor方法,將ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor()改為ThreadPoolTaskExecutor executor = new VisiableThreadPoolTaskExecutor()

@Bean(name = “asyncServiceExecutor”)

public Executor asyncServiceExecutor() {

logger.info(“start asyncServiceExecutor”);

//在這里修改

ThreadPoolTaskExecutor executor = new VisiableThreadPoolTaskExecutor();

//配置核心線程數

executor.setCorePoolSize(corePoolSize);

//配置最大線程數

executor.setMaxPoolSize(maxPoolSize);

//配置隊列大小

executor.setQueueCapacity(queueCapacity);

//配置線程池中的線程的名稱前綴

executor.setThreadNamePrefix(namePrefix);

// rejection-policy:當pool已經達到max size的時候,如何處理新任務

// CALLER_RUNS:不在新線程中執行任務,而是有調用者所在的線程來執行

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

//執行初始化

executor.initialize();

return executor;

}

再次啟動該工程測試

2018-07-16 2230.951 INFO 14088 --- [nio-8087-exec-2] u.d.e.e.i.VisiableThreadPoolTaskExecutor : async-service-, 2. do submit,taskCount [0], completedTaskCount [0], activeCount [0], queueSize [0]

2018-07-16 2230.952 INFO 14088 --- [async-service-1] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2230.953 INFO 14088 --- [async-service-1] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2231.351 INFO 14088 --- [nio-8087-exec-3] u.d.e.e.i.VisiableThreadPoolTaskExecutor : async-service-, 2. do submit,taskCount [1], completedTaskCount [1], activeCount [0], queueSize [0]

2018-07-16 2231.353 INFO 14088 --- [async-service-2] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2231.353 INFO 14088 --- [async-service-2] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2231.927 INFO 14088 --- [nio-8087-exec-5] u.d.e.e.i.VisiableThreadPoolTaskExecutor : async-service-, 2. do submit,taskCount [2], completedTaskCount [2], activeCount [0], queueSize [0]

2018-07-16 2231.929 INFO 14088 --- [async-service-3] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2231.930 INFO 14088 --- [async-service-3] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

2018-07-16 2232.496 INFO 14088 --- [nio-8087-exec-7] u.d.e.e.i.VisiableThreadPoolTaskExecutor : async-service-, 2. do submit,taskCount [3], completedTaskCount [3], activeCount [0], queueSize [0]

2018-07-16 2232.498 INFO 14088 --- [async-service-4] c.u.d.e.executor.impl.AsyncServiceImpl : start executeAsync

異步線程要做的事情

可以在這里執行批量插入等耗時的事情

2018-07-16 2232.499 INFO 14088 --- [async-service-4] c.u.d.e.executor.impl.AsyncServiceImpl : end executeAsync

注意這一行日志:

2018-07-16 2232.496 INFO 14088 --- [nio-8087-exec-7] u.d.e.e.i.VisiableThreadPoolTaskExecutor : async-service-, 2. do submit,taskCount [3], completedTaskCount [3], activeCount [0], queueSize [0]

這說明提交任務到線程池的時候,調用的是submit(Callable task)這個方法,當前已經提交了3個任務,完成了3個,當前有0個線程在處理任務,還剩0個任務在隊列中等待,線程池的基本情況一路了然;

責任編輯:haq

聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • spring
    +關注

    關注

    0

    文章

    341

    瀏覽量

    15122
  • 線程池
    +關注

    關注

    0

    文章

    57

    瀏覽量

    7146
  • SpringBoot
    +關注

    關注

    0

    文章

    175

    瀏覽量

    408

原文標題:SpringBoot中的線程池,你真的會用么?

文章出處:【微信號:AndroidPush,微信公眾號:Android編程精選】歡迎添加關注!文章轉載請注明出處。

收藏 0人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評論

    相關推薦
    熱點推薦

    UVC+MSC實現MSC線程未運行的原因?

    我正在嘗試使用 EZUSB 運行 UVC + MSC。我有以下內容。但看起來只有 UVC 線程在運行,而 MSC 沒有運行。fw 不響應 MSC 命令。我確保 LPM 已被禁用,只是為了檢查傳感器
    發表于 07-16 07:08

    線程的安全注意事項

    線程安全是指多個線程同時訪問或修改共享資源時,能夠保證程序的正確性和可靠性。 開發者選擇TaskPool或Worker進行多線程開發時,在TaskPool和Worker的工作
    發表于 06-20 07:49

    TECS OpenStack資源時間同步失敗的故障分析

    某運營商TECS OpenStack資源,在當前告警顯示“時鐘同步失敗”,以10分鐘整數倍為間隔上報“時間同步失敗”告警,持續時間30秒-1分鐘不等。
    的頭像 發表于 03-03 10:09 ?468次閱讀
    TECS OpenStack資源<b class='flag-5'>池</b>時間同步失敗的故障分析

    ISP與IP地址

    ISP可以為用戶提供互聯網接入、信息內容、應用服務以及其他增值業務。 要知道,在ISP的網絡,IP地址幾乎可以說不可或缺。IP地址是指一定范圍內可供分配的IP地址的集合。通過分配IP地址,設備
    的頭像 發表于 12-27 10:41 ?543次閱讀

    深入探索:海外IP代理的安全性與管理

    海外IP代理的安全性與管理是使用這一工具時不可忽視的重要方面。
    的頭像 發表于 11-14 07:39 ?517次閱讀

    socket 多線程編程實現方法

    在現代網絡編程,多線程技術被廣泛應用于提高服務器的并發處理能力。Socket編程是網絡通信的基礎,而將多線程技術應用于Socket編程,可以顯著提升服務器的性能。 多線程編程的基本概
    的頭像 發表于 11-12 14:16 ?1035次閱讀

    的無線測溫在線監測系統

    今天分享的酒廠窖的無線測溫系統,包含硬件和軟件為一體的標準解決方案。 行業背景 說到窖的測溫,不得不從酒廠的酒廠的發酵說起。酒廠發酵是指用于生產釀酒的一種設備,通常由不銹鋼或玻
    的頭像 發表于 10-28 09:52 ?425次閱讀
    窖<b class='flag-5'>池</b>的無線測溫在線監測系統

    怎么在JAVA確定線性大小

    在JAVA確定線性大小,分別介紹CPU密集型任務和I/O密集型任務及其處理方法。
    的頭像 發表于 10-24 14:02 ?502次閱讀

    Python線程和多進程的區別

    Python作為一種高級編程語言,提供了多種并發編程的方式,其中多線程與多進程是最常見的兩種方式之一。在本文中,我們將探討Python線程與多進程的概念、區別以及如何使用線程
    的頭像 發表于 10-23 11:48 ?1037次閱讀
    Python<b class='flag-5'>中</b>多<b class='flag-5'>線程</b>和多進程的區別

    離心溫度監測物聯網系統方案

    在現有技術的鋼丸生產工藝,一般采用離心法實現鋼丸的成形,其原理是將熔融狀態的鋼水裝入離心機,通過離心力將鋼水甩出離心機,離心機位于一個冷卻的中部,因此從離心機甩出的鋼水落入冷卻
    的頭像 發表于 09-20 10:56 ?377次閱讀
    離心<b class='flag-5'>池</b>溫度監測物聯網系統方案

    買藥秒送 JADE動態線程實踐及原理淺析

    一、背景及JADE介紹 買藥秒送是健康即時零售業務新的核心流量場域,面對京東首頁高流量曝光,我們對頻道頁整個技術架構方案進行升級,保障接口高性能、系統高可用。 動態線程是買藥頻道應用的技術之一
    的頭像 發表于 09-04 11:11 ?1202次閱讀
    買藥秒送 JADE動態<b class='flag-5'>線程</b><b class='flag-5'>池</b>實踐及原理淺析

    CPU線程和程序線程的區別

    CPU的線程與程序的線程在概念、作用、實現方式以及性能影響等方面存在顯著差異。以下是對兩者區別的詳細闡述,旨在深入探討這一技術話題。
    的頭像 發表于 09-02 11:18 ?2156次閱讀

    高壓放大器在鐵磁鐵電異質結系統物理儲備計算的應用

    實驗名稱:高壓放大器在鐵磁鐵電異質結系統物理儲備計算的應用實驗內容:將信號發生器產生的一段任意波形經高壓放大器放大后輸入到系統,探測系統的實時輸出,并對該系統進行儲備計算的模型
    的頭像 發表于 08-23 13:49 ?597次閱讀
    高壓放大器在鐵磁鐵電異質結系統物理儲備<b class='flag-5'>池</b>計算<b class='flag-5'>中</b>的應用

    基于OpenHarmony標準系統的C++公共基礎類庫案例:ThreadPoll

    線程增強及線程等接口 安全數據容器、數據序列化等接口 各子系統的錯誤碼相關定義 2.1、添加C++公共基礎類庫依賴 修改需調用模塊的BUILD.gn,在external_deps或deps
    發表于 08-12 11:42

    一文掌握Python多線程

    使用線程可以把占據長時間的程序的任務放到后臺去處理。
    的頭像 發表于 08-05 15:46 ?1300次閱讀
    主站蜘蛛池模板: 亚洲精品6久久久久中文字幕 | 国精产品砖一区二区三区糖心 | 精品国产三级a | 日韩欧美国产免费看清风阁 | 久久高清内射无套 | 色欲久久精品AV无码 | 性派对xxxhd| 最近中文字幕高清中文字幕MV | 美女被艹网站 | 中文亚洲大香伊蕉不卡一区 | 亚洲人成77777在线视频 | 美女内射视频WWW网站午夜 | 久久精品国产男包 | 四川老师边上网课边被啪视频 | 我们中文在线观看免费完整版 | 久久国产精品久久国产精品 | 1级午夜影院费免区 | 老师我好爽再深一点老师好涨 | 国产真实露脸乱子伦 | 色色色999 | 夜色资源站国产www在线视频 | 青草国产超碰人人添人人碱 | 5G在线观看免费年龄确认18 | 护士日本xx厕所 | 达达兔午夜一级毛片 | 一本道dvd久久综合高清免费 | 美女被男人撕衣舔胸 | 一本大道香蕉中文在线视频观看 | 99久久亚洲精品日本无码 | yellow日本动漫免费观看 | 金发欧美一区在线观看 | 国产人妻人伦精品久久久 | 久久久久亚洲 | 高H高肉强J短篇校园 | 美女一级毛片免费不卡视频 | 国产成人无码精品久久久影院 | 国内国外精品影片无人区 | 果冻传媒2021一二三在线观看 | 年轻夫妇韩剧中文版免费观看 | 久久中文骚妇内射 | 日本边添边摸边做边爱边 |

    電子發燒友

    中國電子工程師最喜歡的網站

    • 2931785位工程師會員交流學習
    • 獲取您個性化的科技前沿技術信息
    • 參加活動獲取豐厚的禮品