Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Configuration
- @EnableScheduling
- public class SchedulerConfig implements SchedulingConfigurer {
- private final int POOL_SIZE = 10;
- @Override
- public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
- ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
- threadPoolTaskScheduler.setPoolSize(POOL_SIZE);
- threadPoolTaskScheduler.setThreadNamePrefix("my-sched-pool-");
- threadPoolTaskScheduler.initialize();
- scheduledTaskRegistrar.setTaskScheduler(threadPoolTaskScheduler);
- }
- }
- @Scheduled(fixedRateString = "2000" )
- public void testaMethod() {
- log.debug("here is the message");
- try {
- Thread.sleep(10000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
- {"thread":"my-sched-pool-1","level":"DEBUG","description":"here is the message"}
- {"thread":"my-sched-pool-1","level":"DEBUG","description":"here is the message"}
- {"thread":"my-sched-pool-1","level":"DEBUG","description":"here is the message"}
- {"thread":"my-sched-pool-1","level":"DEBUG","description":"here is the message"}
Add Comment
Please, Sign In to add comment