| | |
| | | public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { |
| | | //采用定长的线程池,防止定时任务异常时导致大量线程被占用; |
| | | |
| | | // 创建一个 ScheduledThreadPoolExecutor,核心线程数为 12,最大线程数为 24 |
| | | ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(12, new ThreadPoolExecutor.CallerRunsPolicy()); |
| | | // 设置最大线程数为 24 |
| | | executor.setMaximumPoolSize(24); |
| | | // 创建一个 ScheduledThreadPoolExecutor,核心线程数为 12,最大线程数为 50 |
| | | ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(12, new ThreadPoolExecutor.DiscardPolicy()); |
| | | // 设置最大线程数为 50 |
| | | executor.setMaximumPoolSize(50); |
| | | taskRegistrar.setScheduler(executor); |
| | | } |
| | | } |