一、使用SpringBoot實現定時任務

這個不是重點，就簡單的實現一下，至于cron表達式怎么寫也不是重點，自行百度即可。

1-1、基于?@Scheduled?注解的方式

import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;@Component@EnableSchedulingpublic class XdxOne { @Scheduled(cron = "*/1 * * * * ?") public void testOne(){ System.out.println("one " + " "+ Thread.currentThread().getName()); }}

1-2、基于SchedulingConfigurer接口實現

import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;import java.util.Date;@Component // 1.主要用于標記配置類，兼備Component的效果。@EnableScheduling // 2.開啟定時任務public class XdxTestOne implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { Runnable task = new Runnable() { @Override public void run() { Thread t = Thread.currentThread(); String name = t.getName(); System.out.println("XdxTestOne=" + name); } }; Trigger trigger = new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { // 這里我們可以通過去數據庫獲取cron表達式，從而實現動態 CronTrigger trigger = new CronTrigger("*/3 * * * * ?"); Date nextExec = trigger.nextExecutionTime(triggerContext); return nextExec; } }; scheduledTaskRegistrar.addTriggerTask(task, trigger); }}

上面兩種方式都可以實現定時任務，毫無疑問注解方式實現起來更為舒服。但假如你不想把這個cron表達式寫死，對于注解方式我們可能無可奈何(也可能是我沒有找到方法)。但是對于接口的方式，我們可以在設置的時候去數據庫獲取，這樣就實現了動態。

接口方式的定時任務每次執行的時候，都會去執行那個獲取cron的方法。

二、異步實現

上面只是簡單的實現了定時任務，一般來說也沒有什么問題，但是上面的方式是一個線程挨個執行定時任務，這就會導致比如你某個線程是1s執行一次，但是你另外一個定時任務執行一次需要10min，那么你的這個定時任務就會被阻塞。?

? 一般來說可能也不重要，因為只要最后執行就好了，但有時卻是致命的，比我在工作中有一個定時任務是及時去同步數據來處理，這個時候阻塞了就是致命的。因此我們需要開啟異步執行，也就是多線程執行，這樣你一個定時任務阻塞了，還有另外的線程去執行我們的定時任務。

2-1、對于使用@Scheduled注解方式實現異步

我們可以使用?@Async?注解實現異步(異步方法使用注解@Async的返回值只能為void或者Future)，把@Async加在類或者方法上面，然后還需要一個?@EnableAsync來開啟異步。

@EnableAsync可以加在啟動類上面這樣可以直接開啟所有的異步，也可以單獨加在每個類上面。

2-1-1：版本差異

springBoot2.0 和 springBoot2.2 默認的線程池是不一樣的，2.0默認線程池每開啟一個新的任務都是新開一個線程的。2.2默認線程池有8個。

如果你的定時任務比較少，并且執行時間比較短其實上面兩種都沒啥關系。但是如果定時任務多且慢，那么2.0每次創建一個線程可能導致JVM掛掉，而2.2只有8個線程也會滿足不了，會導致任務等待。

2-1-2：自定義線程池

創建一個線程池：

import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;@Configuration@EnableAsyncpublic class AsyncConfig { @Bean(name = "taskExecutor") public ThreadPoolTaskExecutor asyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 核心線程數 executor.setCorePoolSize(10); // 最大線程數 executor.setMaxPoolSize(50); // 隊列最大長度 executor.setQueueCapacity(1000); // 線程池維護線程所允許的空閑時間 executor.setKeepAliveSeconds(100); // 線程前綴 executor.setThreadNamePrefix("AsyncExecutorThread-"); // 線程池對拒絕任務(無線程可用)的處理策略 executor.setRejectedExecutionHandler(new CallerRunsPolicy()); executor.initialize(); return executor; }}

我們創建了上面的線程池后，所有的任務都將使用這個線程池里面的線程(可以通過輸出線程名查看)

但是如果我們有多個線程池的時候，這個時候我們可以使用?@Async(“name”)?name就是線程池的名字，沒有寫name的時候默認使用bean為taskExecutor?的線程池。

2-2、對于使用接口的方式實現異步

而對于使用注解的定時任務，如果你沒有使用@Async注解給它指定線程池(可以理解默認name = taskExecutor，如果你沒有taskExecutor線程池就會使用默認線程池)，它也會使用接口里面創建的線程池進行調用。

三、其它

@EnableScheduling注解是開啟定時任務的，隨便放在那里都可以，只需要一個。

---

總結

以上是生活随笔為你收集整理的定时线程_SpringBoot定时任务，@Async多线程异步执行的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。