| | |
| | | import org.springframework.context.annotation.Configuration; |
| | | import org.springframework.scheduling.annotation.EnableScheduling; |
| | | import org.springframework.scheduling.annotation.SchedulingConfigurer; |
| | | import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; |
| | | import org.springframework.scheduling.config.ScheduledTaskRegistrar; |
| | | |
| | | import java.util.concurrent.Executors; |
| | |
| | | |
| | | @Override |
| | | public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { |
| | | scheduledTaskRegistrar.setScheduler(Executors.newScheduledThreadPool(100)); |
| | | ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); |
| | | taskScheduler.setPoolSize(10); |
| | | taskScheduler.initialize(); |
| | | scheduledTaskRegistrar.setScheduler(taskScheduler); |
| | | } |
| | | } |