av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Spring boot使用多線程過程步驟解析

瀏覽:4日期:2023-08-24 08:32:21

Spring中實現多線程,其實非常簡單,只需要在配置類中添加@EnableAsync就可以使用多線程。在希望執行的并發方法中使用@Async就可以定義一個線程任務。通過spring給我們提供的ThreadPoolTaskExecutor就可以使用線程池。

第一步,先在Spring Boot主類中定義一個線程池,比如:

package com.jmxf.core.config;import java.util.concurrent.Executor;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;@Configuration@EnableAsync // 啟用異步任務public class AsyncConfiguration { // 組件計算 @Bean('zjExecutor') public Executor asyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); //核心線程數5:線程池創建時候初始化的線程數 executor.setCorePoolSize(5); //最大線程數5:線程池最大的線程數,只有在緩沖隊列滿了之后才會申請超過核心線程數的線程 executor.setMaxPoolSize(10); //緩沖隊列500:用來緩沖執行任務的隊列 executor.setQueueCapacity(500); //允許線程的空閑時間60秒:當超過了核心線程出之外的線程在空閑時間到達之后會被銷毀 executor.setKeepAliveSeconds(60); //線程池名的前綴:設置好了之后可以方便我們定位處理任務所在的線程池 executor.setThreadNamePrefix('DailyAsync-'); executor.initialize(); return executor; }}

有很多你可以配置的東西。默認情況下,使用SimpleAsyncTaskExecutor。

第二步,使用線程池

在定義了線程池之后,我們如何讓異步調用的執行任務使用這個線程池中的資源來運行呢?方法非常簡單,我們只需要在@Async注解中指定線程池名即可,比如:

package com.jmxf.service.fkqManage.zj;import org.springframework.scheduling.annotation.Async;@Servicepublic class CentreZj { /** * 多線程執行 zj計算推數 * @param fkqZj * @throws Exception */ @Async('zjExecutor') public CompletableFuture<String> executeZj (FkqZj fkqZj) { if(fkqZj == null) return; String zjid = fkqZj.getZjid(); FkqHdzjdm zjdm = getZjdm(zjid); String zjlj = zjdm.getZjlj(); if(StringUtils.isBlank(zjlj)) return; Object bean = ApplicationContextProvider.getBean(zjlj); Method method; try { method = bean.getClass().getMethod('refresh',String.class); method.invoke(bean,zjid); } catch (Exception e) { e.printStackTrace(); } } return CompletableFuture.completedFuture(zjid);}

executeZj方法被標記為Spring的 @Async 注解,表示它將在一個單獨的線程上運行。該方法的返回類型是 CompleetableFuture 而不是 String,這是任何異步服務的要求。

第三步,調用測試

List<CompletableFuture<String>> executeZjs = new ArrayList<>(); for (FkqZj fkqZj : zjs) { CompletableFuture<String> executeZj = centreZj.executeZj(fkqZj); executeZjs.add(executeZj); } //等待所以子線程結束后 返回結果 for (CompletableFuture<String> completableFuture : executeZjs) { CompletableFuture.allOf(completableFuture).join(); }

注意事項

異步方法和調用方法一定要寫在不同的類中 ,如果寫在一個類中,是沒有效果的!

原因:

spring對@Transactional注解時也有類似問題,spring掃描時具有@Transactional注解方法的類時,是生成一個代理類,由代理類去開啟關閉事務,而在同一個類中,方法調用是在類體內執行的,spring無法截獲這個方法調用。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 91精品国产色综合久久不卡98口 | 日韩成人精品一区二区三区 | 中文字幕视频网 | 超碰97人人人人人蜜桃 | 精品区| 国产精品久久久久久久久久久久久久 | 欧美三区在线观看 | 成人久久久 | 欧美激情久久久久久 | 国产精品区二区三区日本 | 久热久| 亚洲天堂av在线 | 久久综合一区二区 | 欧美日韩一区精品 | h肉视频| 日本特黄a级高清免费大片 国产精品久久性 | 中文字幕免费中文 | 久久久久久91 | 欧美成人一区二免费视频软件 | 久久中文字幕一区 | 亚洲日本欧美日韩高观看 | 国产91在线 | 亚洲 | 91九色在线观看 | 中文字幕日本一区二区 | 日韩视频在线一区 | 91动漫在线观看 | 国产在线看片 | 一区二区三区在线 | 欧 | 99久久99久久精品国产片果冰 | 亚洲一区二区 | 综合色播| 亚洲看片网站 | 欧美在线a | 女同av亚洲女人天堂 | 国产在线中文字幕 | 亚洲激精日韩激精欧美精品 | 欧美视频1 | 欧美久久久久久 | 亚洲a视频 | 亚洲人成人一区二区在线观看 | 一区二区免费 |