springboot2.0以上調(diào)度器如何配置線程池-創(chuàng)新互聯(lián)

這篇文章給大家分享的是有關(guān)springboot2.0以上調(diào)度器如何配置線程池的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

創(chuàng)新互聯(lián)是一家從事企業(yè)網(wǎng)站建設(shè)、成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計、行業(yè)門戶網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計制作的專業(yè)網(wǎng)絡(luò)公司，擁有經(jīng)驗(yàn)豐富的網(wǎng)站建設(shè)工程師和網(wǎng)頁設(shè)計人員，具備各種規(guī)模與類型網(wǎng)站建設(shè)的實(shí)力，在網(wǎng)站建設(shè)領(lǐng)域樹立了自己獨(dú)特的設(shè)計風(fēng)格。自公司成立以來曾獨(dú)立設(shè)計制作的站點(diǎn)上1000+。

　　springboot2.0 以上spring task 開啟多線程

　　一 我們使用@EnableScheduling 開啟spring task 調(diào)度器的時候，發(fā)現(xiàn)此調(diào)度器默認(rèn)配置為單線程的。

　　二 打開注解發(fā)現(xiàn)其配置信息在此SchedulingConfiguration類中。發(fā)現(xiàn)其創(chuàng)建了ScheduledTaskRegistrar類

　　研讀代碼不難發(fā)現(xiàn)調(diào)度器默認(rèn)配置是如下代碼，線程池為單線程的。

　　protected void scheduleTasks() {

　　if (this.taskScheduler == null) {

　　this.localExecutor = Executors.newSingleThreadScheduledExecutor();

　　this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);

　　}

　　if (this.triggerTasks != null) {

　　for (TriggerTask task : this.triggerTasks) {

　　addScheduledTask(scheduleTriggerTask(task));

　　}

　　}

　　if (this.cronTasks != null) {

　　for (CronTask task : this.cronTasks) {

　　addScheduledTask(scheduleCronTask(task));

　　}

　　}

　　if (this.fixedRateTasks != null) {

　　for (IntervalTask task : this.fixedRateTasks) {

　　addScheduledTask(scheduleFixedRateTask(task));

　　}

　　}

　　if (this.fixedDelayTasks != null) {

　　for (IntervalTask task : this.fixedDelayTasks) {

　　addScheduledTask(scheduleFixedDelayTask(task));

　　}

　　}

　　}

　　如何改變此配置呢?

　　如果想改變其中配置則只需要如下核心代碼

　　package com.ccbobe.common.config;

　　import org.springframework.context.annotation.Bean;

　　import org.springframework.context.annotation.Configuration;

　　import org.springframework.scheduling.annotation.EnableScheduling;

　　import org.springframework.scheduling.annotation.SchedulingConfigurer;

　　import org.springframework.scheduling.config.ScheduledTaskRegistrar;

　　import java.util.concurrent.ScheduledExecutorService;

　　import java.util.concurrent.ScheduledThreadPoolExecutor;

　　@EnableScheduling

　　@Configuration

　　public class SchedulerConfig implements SchedulingConfigurer {

　　@Bean鄭州做人流手術(shù) http://rl.zyfuke.com/

　　public ScheduledExecutorService concurrentTaskScheduler(){

　　ScheduledThreadPoolExecutor executorService = new ScheduledThreadPoolExecutor(20);

　　executorService.setMaximumPoolSize(20);

　　executorService.setRejectedExecutionHandler(new ScheduledThreadPoolExecutor.CallerRunsPolicy());

　　return executorService;

　　}

　　@Override

　　public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

　　taskRegistrar.setScheduler(concurrentTaskScheduler());

　　}

　　}

　　其中Scheduler 支持兩種，種分別是：TaskScheduler 和 ScheduledExecutorService

　　**

　　* Set the {@link TaskScheduler} to register scheduled tasks with, or a

　　* {@link java.util.concurrent.ScheduledExecutorService} to be wrapped as a

　　* {@code TaskScheduler}.

　　*/

　　public void setScheduler(@Nullable Object scheduler) {

　　if (scheduler == null) {

　　this.taskScheduler = null;

　　}

　　else if (scheduler instanceof TaskScheduler) {

　　this.taskScheduler = (TaskScheduler) scheduler;

　　}

　　else if (scheduler instanceof ScheduledExecutorService) {

　　this.taskScheduler = new ConcurrentTaskScheduler(((ScheduledExecutorService) scheduler));

　　}

　　else {

　　throw new IllegalArgumentException("Unsupported scheduler type: " + scheduler.getClass());

　　}

　　}

　　完成以上配置，即可讓spring task 運(yùn)行在多線程環(huán)境中。

感謝各位的閱讀！關(guān)于“springboot2.0以上調(diào)度器如何配置線程池”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

文章題目：springboot2.0以上調(diào)度器如何配置線程池-創(chuàng)新互聯(lián)
網(wǎng)站地址：http://muchs.cn/article46/djedhg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站設(shè)計、標(biāo)簽優(yōu)化、網(wǎng)站改版、網(wǎng)站設(shè)計公司、微信小程序、響應(yīng)式網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)