| | |
| | | //配置队列大小 |
| | | executor.setQueueCapacity(1000); |
| | | //线程的名称前缀 |
| | | executor.setThreadNamePrefix("alarmExecutor-"); |
| | | //线程活跃时间(秒) |
| | | //executor.setKeepAliveSeconds(60); |
| | | //等待所有任务结束后再关闭线程池 |
| | | executor.setWaitForTasksToCompleteOnShutdown(true); |
| | | //设置拒绝策略 |
| | | //executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); |
| | | //执行初始化 |
| | | executor.initialize(); |
| | | return executor; |
| | | } |
| | | @Bean("exec") |
| | | public ThreadPoolTaskExecutor executor(){ |
| | | ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); |
| | | //配置核心线程数 |
| | | executor.setCorePoolSize(15); |
| | | //配置最大线程数 |
| | | executor.setMaxPoolSize(30); |
| | | //配置队列大小 |
| | | executor.setQueueCapacity(1000); |
| | | //线程的名称前缀 |
| | | executor.setThreadNamePrefix("Executor-"); |
| | | //线程活跃时间(秒) |
| | | //executor.setKeepAliveSeconds(60); |