1. 程式人生 > >解決@Scheduled註解定時任務併發執行

解決@Scheduled註解定時任務併發執行

如下程式碼,是一個簡單的通過@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;
    }
}