| File was renamed from ard-work/src/main/java/com/ruoyi/device/hiksdk/config/AsyncConfiguration.java |
| | |
| | | package com.ruoyi.device.hiksdk.config; |
| | | package com.ruoyi.config; |
| | | |
| | | import org.springframework.context.annotation.Bean; |
| | | import org.springframework.context.annotation.Configuration; |
| | |
| | | executor.initialize(); |
| | | return executor; |
| | | } |
| | | @Bean("alarmExecutor") |
| | | public Executor alarmExecutor(){ |
| | | ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); |
| | | //配置核心线程数 |
| | | executor.setCorePoolSize(15); |
| | | //配置最大线程数 |
| | | executor.setMaxPoolSize(30); |
| | | //配置队列大小 |
| | | executor.setQueueCapacity(1000); |
| | | //线程的名称前缀 |
| | | executor.setThreadNamePrefix("alarmExecutor-"); |
| | | //线程活跃时间(秒) |
| | | //executor.setKeepAliveSeconds(60); |
| | | //等待所有任务结束后再关闭线程池 |
| | | executor.setWaitForTasksToCompleteOnShutdown(true); |
| | | //设置拒绝策略 |
| | | //executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); |
| | | //执行初始化 |
| | | executor.initialize(); |
| | | return executor; |
| | | } |
| | | } |