教你優(yōu)雅的實(shí)現(xiàn) SpringBoot 并行任務(wù)
閱讀本文大概需要 4.5 分鐘。
來自：wangjiuyin.blog.csdn.net/article/details/79411952
第一種：把參數(shù)配置到.properties文件中：
package com.accord.task;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
/**
* 從配置文件加載任務(wù)信息
* @author 王久印
*/
@Component
public class ScheduledTask {
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
//@Scheduled(fixedDelayString = "${jobs.fixedDelay}")
@Scheduled(fixedDelayString = "2000")
public void getTask1() {
System.out.println("任務(wù)1,從配置文件加載任務(wù)信息，當(dāng)前時(shí)間：" + dateFormat.format(new Date()));
}
@Scheduled(cron = "${jobs.cron}")
public void getTask2() {
System.out.println("任務(wù)2,從配置文件加載任務(wù)信息，當(dāng)前時(shí)間：" + dateFormat.format(new Date()));
}
}
jobs.fixedDelay=5000
jobs.cron=0/5 * * * * ?
package com.accord;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableScheduling
public class SpringBootCron2Application {
public static void main(String[] args) {
SpringApplication.run(SpringBootCron2Application.class, args);
}
}
注：@EnableScheduling 這個(gè)一定要加上；否則，不會(huì)定時(shí)啟動(dòng)任務(wù)！
@Scheduled(fixedRate=2000)：上一次開始執(zhí)行時(shí)間點(diǎn)后2秒再次執(zhí)行；@Scheduled(fixedDelay=2000)：上一次執(zhí)行完畢時(shí)間點(diǎn)后2秒再次執(zhí)行；@Scheduled(initialDelay=1000, fixedDelay=2000)：第一次延遲1秒執(zhí)行，然后在上一次執(zhí)行完畢時(shí)間點(diǎn)后2秒再次執(zhí)行；@Scheduled(cron="* * * * * ?")：按cron規(guī)則執(zhí)行。
http://cron.qqe2.com/第二種定時(shí)任務(wù)：單線程和多線程
1、創(chuàng)建定時(shí)任務(wù)：
package com.accord.task;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
/**
* 構(gòu)建執(zhí)行定時(shí)任務(wù)
* @author 王久印
* TODO
*/
@Component
public class ScheduledTask2 {
private Logger logger = LoggerFactory.getLogger(ScheduledTask2.class);
private int fixedDelayCount = 1;
private int fixedRateCount = 1;
private int initialDelayCount = 1;
private int cronCount = 1;
@Scheduled(fixedDelay = 5000) //fixedDelay = 5000表示當(dāng)前方法執(zhí)行完畢5000ms后，Spring scheduling會(huì)再次調(diào)用該方法
public void testFixDelay() {
logger.info("===fixedDelay: 第{}次執(zhí)行方法", fixedDelayCount++);
}
@Scheduled(fixedRate = 5000) //fixedRate = 5000表示當(dāng)前方法開始執(zhí)行5000ms后，Spring scheduling會(huì)再次調(diào)用該方法
public void testFixedRate() {
logger.info("===fixedRate: 第{}次執(zhí)行方法", fixedRateCount++);
}
@Scheduled(initialDelay = 1000, fixedRate = 5000) //initialDelay = 1000表示延遲1000ms執(zhí)行第一次任務(wù)
public void testInitialDelay() {
logger.info("===initialDelay: 第{}次執(zhí)行方法", initialDelayCount++);
}
@Scheduled(cron = "0 0/1 * * * ?") //cron接受cron表達(dá)式，根據(jù)cron表達(dá)式確定定時(shí)規(guī)則
public void testCron() {
logger.info("===initialDelay: 第{}次執(zhí)行方法", cronCount++);
}
}
cron：cron表達(dá)式，指定任務(wù)在特定時(shí)間執(zhí)行； fixedDelay：表示上一次任務(wù)執(zhí)行完成后多久再次執(zhí)行，參數(shù)類型為long，單位ms； fixedDelayString：與fixedDelay含義一樣，只是參數(shù)類型變?yōu)镾tring； fixedRate：表示按一定的頻率執(zhí)行任務(wù)，參數(shù)類型為long，單位ms； fixedRateString: 與fixedRate的含義一樣，只是將參數(shù)類型變?yōu)镾tring； initialDelay：表示延遲多久再第一次執(zhí)行任務(wù)，參數(shù)類型為long，單位ms； initialDelayString：與initialDelay的含義一樣，只是將參數(shù)類型變?yōu)镾tring； zone：時(shí)區(qū)，默認(rèn)為當(dāng)前時(shí)區(qū)，一般沒有用到。
2、開啟定時(shí)任務(wù)：
package com.accord;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableScheduling
public class SpringBootCron2Application {
public static void main(String[] args) {
SpringApplication.run(SpringBootCron2Application.class, args);
}
}
注：這里的 @EnableScheduling 注解，它的作用是發(fā)現(xiàn)注解 @Scheduled的任務(wù)并由后臺(tái)執(zhí)行。沒有它的話將無法執(zhí)行定時(shí)任務(wù)。
@EnableScheduling ensures that a background task executor is created. Without it, nothing gets scheduled.
3、執(zhí)行結(jié)果（單線程）
4、多線程處理定時(shí)任務(wù)：
SingleThreadScheduledExecutor，于是我看了源碼，從ScheduledAnnotationBeanPostProcessor類開始一路找下去。果然，在ScheduledTaskRegistrar（定時(shí)任務(wù)注冊類）中的ScheduleTasks中又這樣一段判斷：if (this.taskScheduler == null) {
this.localExecutor = Executors.newSingleThreadScheduledExecutor();
this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
}
taskScheduler為空，那么就給定時(shí)任務(wù)做了一個(gè)單線程的線程池，正好在這個(gè)類中還有一個(gè)設(shè)置taskScheduler的方法：public void setScheduler(Object scheduler) {
Assert.notNull(scheduler, "Scheduler object must not be null");
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());
}
}
ScheduledExecutorService就可以達(dá)到并發(fā)的效果了。我們要做的僅僅是實(shí)現(xiàn)SchedulingConfigurer接口，重寫configureTasks方法就OK了；package com.accord.task;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import java.util.concurrent.Executors;
/**
* 多線程執(zhí)行定時(shí)任務(wù)
* @author 王久印
*/
@Configuration
//所有的定時(shí)任務(wù)都放在一個(gè)線程池中，定時(shí)任務(wù)啟動(dòng)時(shí)使用不同都線程。
public class ScheduleConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
//設(shè)定一個(gè)長度10的定時(shí)任務(wù)線程池
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
}
}
5、執(zhí)行結(jié)果（并發(fā)）
推薦閱讀：
為什么很多 SpringBoot 開發(fā)者放棄了 Tomcat，選擇了 Undertow？
互聯(lián)網(wǎng)初中高級(jí)大廠面試題(9個(gè)G) 內(nèi)容包含Java基礎(chǔ)、JavaWeb、MySQL性能優(yōu)化、JVM、鎖、百萬并發(fā)、消息隊(duì)列、高性能緩存、反射、Spring全家桶原理、微服務(wù)、Zookeeper......等技術(shù)棧！
?戳閱讀原文領(lǐng)?。?/span> 朕已閱
評論
圖片
表情