From 57019123c927bdf007220df5ddcdd2c5ecfb4322 Mon Sep 17 00:00:00 2001
From: Xiajijian <1176061145@qq.com>
Date: Fri, 21 Aug 2026 11:29:48 +0800
Subject: [PATCH] 1. 配置文件提交。

---
 ard-framework/src/main/java/com/ard/framework/config/ThreadPoolConfig.java |   30 +++++++++++++++++++++++++++++-
 1 files changed, 29 insertions(+), 1 deletions(-)

diff --git a/ard-framework/src/main/java/com/ard/framework/config/ThreadPoolConfig.java b/ard-framework/src/main/java/com/ard/framework/config/ThreadPoolConfig.java
index d005095..76c3a93 100644
--- a/ard-framework/src/main/java/com/ard/framework/config/ThreadPoolConfig.java
+++ b/ard-framework/src/main/java/com/ard/framework/config/ThreadPoolConfig.java
@@ -13,7 +13,7 @@
 /**
  * 线程池配置
  *
- * @author ruoyi
+ * @author ard
  **/
 @Configuration
 public class ThreadPoolConfig
@@ -62,4 +62,32 @@
             }
         };
     }
+    @Bean("mediaVideoExecutor")
+    public ThreadPoolTaskExecutor mediaVideoExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);    // 核心线程数:同时处理视频的核心线程数
+        executor.setMaxPoolSize(10);     // 最大线程数:线程池不会扩展超过这个数量
+        executor.setQueueCapacity(50);   // 队列容量:等待执行的任务数量,之前20太小可能会拒绝任务
+        executor.setThreadNamePrefix("media-video-");
+
+        // 当线程池和队列都满时的拒绝策略
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+
+        executor.initialize();
+        return executor;
+    }
+    @Bean("mediaPicExecutor")
+    public ThreadPoolTaskExecutor mediaPicExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(10);    // 核心线程数:同时处理视频的核心线程数
+        executor.setMaxPoolSize(10);     // 最大线程数:线程池不会扩展超过这个数量
+        executor.setQueueCapacity(50);   // 队列容量:等待执行的任务数量,之前20太小可能会拒绝任务
+        executor.setThreadNamePrefix("media-pic-");
+
+        // 当线程池和队列都满时的拒绝策略
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
+
+        executor.initialize();
+        return executor;
+    }
 }

--
Gitblit v1.9.3