|
|
@@ -1,15 +1,16 @@
|
|
|
package com.railway.framework.config;
|
|
|
|
|
|
+import java.util.concurrent.ScheduledExecutorService;
|
|
|
import javax.annotation.Resource;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
import org.springframework.scheduling.annotation.SchedulingConfigurer;
|
|
|
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
|
|
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
|
|
import org.springframework.scheduling.support.CronTrigger;
|
|
|
|
|
|
/**
|
|
|
* 基于接口SchedulingConfigurer的动态定时任务
|
|
|
+ * @author fenghao
|
|
|
*/
|
|
|
@Configuration
|
|
|
@EnableScheduling
|
|
|
@@ -29,7 +30,7 @@ public abstract class ConfigurerSchedulingTask implements SchedulingConfigurer {
|
|
|
*/
|
|
|
@Override
|
|
|
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
|
|
|
- ThreadPoolTaskExecutor executor = threadConfig.threadPoolTaskExecutor();
|
|
|
+ ScheduledExecutorService executor = threadConfig.scheduledExecutorService();
|
|
|
taskRegistrar.setScheduler(executor);
|
|
|
taskRegistrar.addTriggerTask(
|
|
|
//执行定时任务
|