解決@Scheduled註解定時任務併發執行
阿新 • • 發佈:2019-02-18
如下程式碼,是一個簡單的通過@Scheduled註解實現的定時任務,每隔5秒執行一次。
@Component public class SchedualDemo { @Autowired DateUtils dateUtils; @Scheduled(fixedDelay = 5000) public void say() { System.out.println("method say: hello " + dateUtils.getCurrentTime()); try { Thread.sleep(6000); } catch (InterruptedException e) { e.printStackTrace(); } } }
但當代碼中存在多個定時任務時,定時任務之間是序列執行,這是Spring限制。
可以在spring.xml配置檔案中加入
<task:annotation-driven scheduler="scheduler"/>
<task:scheduler id="scheduler" pool-size="5"/>
用於設定執行緒池,這樣多個定時任務就可以並行執行。
如果是沒有spring.xml配置檔案的spring工程,可複寫一個ScheduledThreadPoolExecutor的bean,即可實現定時任務的併發執行
@Configuration public class AppConfig { @Bean public ScheduledThreadPoolExecutor scheduledExecutorService() { ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(10); return executor; } }