diff --git a/pom.xml b/pom.xml index 3d8ed97b5..5e764e91c 100644 --- a/pom.xml +++ b/pom.xml @@ -810,7 +810,7 @@ org.example - wflow-server1 + wflow-server 1.0-SNAPSHOT system ${basedir}/src/main/resources/lib/wflow-server-1.0-SNAPSHOT.jar diff --git a/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java b/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java index 592ad5f03..9bbd15f2c 100644 --- a/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java +++ b/src/main/java/com/zhgd/xmgl/config/AsyncConfig.java @@ -1,331 +1,329 @@ -//package com.zhgd.xmgl.config; -// -//import org.springframework.context.annotation.Bean; -//import org.springframework.context.annotation.Configuration; -//import org.springframework.context.annotation.Primary; -//import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; -// -//import java.util.concurrent.ThreadPoolExecutor; -// -///** -// * @program: wisdomSite -// * @description: 线程池配置 -// * @author: Mr.Peng -// * @create: 2021-02-23 10:04 -// **/ -//@Configuration -//public class AsyncConfig { -// /** -// * Set the ThreadPoolExecutor's core pool size. -// */ -// private int corePoolSize = 8; -// /** -// * Set the ThreadPoolExecutor's maximum pool size. -// */ -// private int maxPoolSize = 16; -// /** -// * Set the capacity for the ThreadPoolExecutor's BlockingQueue. -// */ -// private int queueCapacity = 200; -// -// /** -// * 默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务, -// * 当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; -// * 当队列满了,就继续创建线程,当线程数量大于等于maxPoolSize后,开始使用拒绝策略拒绝 -// */ -// -// @Primary -// @Bean("taskExecutor") -// public ThreadPoolTaskExecutor taskExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("taskExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// /** -// * 默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务, -// * 当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; -// * 当队列满了,就继续创建线程,当线程数量大于等于maxPoolSize后,开始使用拒绝策略拒绝 -// */ -// -// @Primary -// @Bean("doubleCarbonExecutor") -// public ThreadPoolTaskExecutor doubleCarbonExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("doubleCarbonExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Primary -// @Bean("countAttendanceExecutor") -// public ThreadPoolTaskExecutor attendanceExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("countAttendanceExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Primary -// @Bean("sendAttendanceExecutor") -// public ThreadPoolTaskExecutor sendAttendanceExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("sendAttendanceExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("sendWorkerExecutor") -// public ThreadPoolTaskExecutor sendWorkerExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("sendWorkerExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("sendExitWorkerExecutor") -// public ThreadPoolTaskExecutor sendExitWorkerExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("sendExitWorkerExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("environmentNoiseDataExecutor") -// public ThreadPoolTaskExecutor sendEnvironmentNoiseDataExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("environmentNoiseDataExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("electricalExecutor") -// public ThreadPoolTaskExecutor sendElectricalExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("electricalExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("towerExecutor") -// public ThreadPoolTaskExecutor sendTowerExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("towerExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("lifterExecutor") -// public ThreadPoolTaskExecutor sendLifterExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("lifterExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("devExcavationExecutor") -// public ThreadPoolTaskExecutor sendDevExcavationEExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("devExcavationExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("gantryCraneExecutor") -// public ThreadPoolTaskExecutor sendGantryCraneExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("gantryCraneExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("fileExecutor") -// public ThreadPoolTaskExecutor fileExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("fileExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("asyncExecutor") -// public ThreadPoolTaskExecutor asyncExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(queueCapacity); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("asyncExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -// -// @Bean("bimExecutor") -// public ThreadPoolTaskExecutor bimExecutor() { -// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); -// /** 核心线程数(默认线程数) */ -// executor.setCorePoolSize(corePoolSize); -// /** 最大线程数 */ -// executor.setMaxPoolSize(maxPoolSize); -// executor.setQueueCapacity(2000); -// /** 允许线程空闲时间(单位:默认为秒) */ -// executor.setKeepAliveSeconds(60); -// /** 线程池名前缀 */ -// executor.setThreadNamePrefix("bimExecutor-"); -// // 线程池对拒绝任务的处理策略 -// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); -// // 初始化 -// executor.initialize(); -// return executor; -// } -//} +package com.zhgd.xmgl.config; + +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Primary; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; + +import java.util.concurrent.ThreadPoolExecutor; + +/** + * @program: wisdomSite + * @description: 线程池配置 + * @author: Mr.Peng + * @create: 2021-02-23 10:04 + **/ +@Configuration +public class AsyncConfig { + /** + * Set the ThreadPoolExecutor's core pool size. + */ + private int corePoolSize = 8; + /** + * Set the ThreadPoolExecutor's maximum pool size. + */ + private int maxPoolSize = 16; + /** + * Set the capacity for the ThreadPoolExecutor's BlockingQueue. + */ + private int queueCapacity = 200; + + /** + * 默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务, + * 当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; + * 当队列满了,就继续创建线程,当线程数量大于等于maxPoolSize后,开始使用拒绝策略拒绝 + */ + + @Primary + @Bean("taskExecutor") + public ThreadPoolTaskExecutor taskExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("taskExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + /** + * 默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务, + * 当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中; + * 当队列满了,就继续创建线程,当线程数量大于等于maxPoolSize后,开始使用拒绝策略拒绝 + */ + + @Bean("doubleCarbonExecutor") + public ThreadPoolTaskExecutor doubleCarbonExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("doubleCarbonExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("countAttendanceExecutor") + public ThreadPoolTaskExecutor attendanceExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("countAttendanceExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("sendAttendanceExecutor") + public ThreadPoolTaskExecutor sendAttendanceExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("sendAttendanceExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("sendWorkerExecutor") + public ThreadPoolTaskExecutor sendWorkerExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("sendWorkerExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("sendExitWorkerExecutor") + public ThreadPoolTaskExecutor sendExitWorkerExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("sendExitWorkerExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("environmentNoiseDataExecutor") + public ThreadPoolTaskExecutor sendEnvironmentNoiseDataExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("environmentNoiseDataExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("electricalExecutor") + public ThreadPoolTaskExecutor sendElectricalExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("electricalExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("towerExecutor") + public ThreadPoolTaskExecutor sendTowerExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("towerExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("lifterExecutor") + public ThreadPoolTaskExecutor sendLifterExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("lifterExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("devExcavationExecutor") + public ThreadPoolTaskExecutor sendDevExcavationEExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("devExcavationExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("gantryCraneExecutor") + public ThreadPoolTaskExecutor sendGantryCraneExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("gantryCraneExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("fileExecutor") + public ThreadPoolTaskExecutor fileExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("fileExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Bean("asyncExecutor") + public ThreadPoolTaskExecutor asyncExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(queueCapacity); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("asyncExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } + + @Primary + @Bean("bimExecutor") + public ThreadPoolTaskExecutor bimExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + /** 核心线程数(默认线程数) */ + executor.setCorePoolSize(corePoolSize); + /** 最大线程数 */ + executor.setMaxPoolSize(maxPoolSize); + executor.setQueueCapacity(2000); + /** 允许线程空闲时间(单位:默认为秒) */ + executor.setKeepAliveSeconds(60); + /** 线程池名前缀 */ + executor.setThreadNamePrefix("bimExecutor-"); + // 线程池对拒绝任务的处理策略 + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + // 初始化 + executor.initialize(); + return executor; + } +} diff --git a/src/main/resources/lib/wflow-server-1.0-SNAPSHOT.jar b/src/main/resources/lib/wflow-server-1.0-SNAPSHOT.jar deleted file mode 100644 index 15fa179ba..000000000 Binary files a/src/main/resources/lib/wflow-server-1.0-SNAPSHOT.jar and /dev/null differ