初始化线程池

amos-boot-system-jxiop/amos-boot-module-jxiop-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/config/JxiopExecutorConfig.java

+package com.yeejoin.amos.boot.module.jxiop.biz.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/7/3
+ */
+@Slf4j
+@Configuration
+@EnableAsync
+public class JxiopExecutorConfig {
+
+
+    @Bean(name = "jxiopAsyncExecutor")
+    public Executor asyncServiceExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        //配置核心线程数
+        executor.setCorePoolSize(30);
+        //配置最大线程数
+        executor.setMaxPoolSize(500);
+        //配置队列大小
+        executor.setQueueCapacity(3000);
+        //配置线程池中的线程的名称前缀
+        executor.setThreadNamePrefix("jxiop");
+        //线程池维护线程所允许的空闲时间
+        executor.setKeepAliveSeconds(10);
+        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
+        // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行--拒绝策略
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+        //执行初始化
+        executor.initialize();
+        //等待所有任务结束后再关闭线程池
+        executor.setWaitForTasksToCompleteOnShutdown(true);
+        return executor;
+    }
+}