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