Created
December 25, 2016 09:08
-
-
Save hn5092/f281d886424f65dc3ec29eba8c278700 to your computer and use it in GitHub Desktop.
如何动态的使用spring的调度,支持cron 表达式
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import org.slf4j.Logger; | |
import org.slf4j.LoggerFactory; | |
import org.springframework.context.annotation.Bean; | |
import org.springframework.context.annotation.Configuration; | |
import org.springframework.scheduling.TaskScheduler; | |
import org.springframework.scheduling.annotation.SchedulingConfigurer; | |
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; | |
import org.springframework.scheduling.config.ScheduledTaskRegistrar; | |
@Configuration | |
public class SchedulerConfig implements SchedulingConfigurer { | |
private static final Logger log = LoggerFactory.getLogger(SchedulerConfig.class); | |
@Override | |
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { | |
scheduledTaskRegistrar.setScheduler(threadPoolTaskScheduler() ); | |
} | |
@Bean | |
public ThreadPoolTaskScheduler threadPoolTaskScheduler() { | |
ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); | |
threadPoolTaskScheduler.setPoolSize(10); | |
return threadPoolTaskScheduler; | |
} | |
// | |
@Bean | |
public TaskScheduler poolScheduler() { | |
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler(); | |
scheduler.setThreadNamePrefix("poolScheduler"); | |
scheduler.setPoolSize(10); | |
return scheduler; | |
} | |
//TODO 配置线程池 | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment