refactor: 首页推荐问生成 转用公共业务线程池

src/main/java/cn/com/poc/common/pool/CommunicationThreadPoolExecutor.java → src/main/java/cn/com/poc/common/pool/CommonThreadPoolExecutor.java

@@ -8,15 +8,15 @@ import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 
 /**
- * Communication 线程池
+ * 公共业务线程池
  */
-public class CommunicationThreadPoolExecutor {
+public class CommonThreadPoolExecutor {
 
-    final private static String THREAD_POOL_NAME = "CommunicationThreadExecutor";
+    final private static String THREAD_POOL_NAME = "Common_Thread_Executor";
 
     final private static int CORE_POOL_SIZE = Runtime.getRuntime().availableProcessors();
 
-    final private static int MAXIMUM_POOL_SIZE = Runtime.getRuntime().availableProcessors() * 5;
+    final private static int MAXIMUM_POOL_SIZE = Runtime.getRuntime().availableProcessors() * 20;
 
     final private static int KEEP_ALIVE_TIME = 60;
 

src/main/java/cn/com/poc/expose/aggregate/impl/AgentApplicationServiceImpl.java

@@ -10,6 +10,7 @@ import cn.com.poc.agent_application.service.BizAgentApplicationDialoguesRecordSe
 import cn.com.poc.agent_application.service.BizAgentApplicationGcConfigService;
 import cn.com.poc.agent_application.service.BizAgentApplicationPublishService;
 import cn.com.poc.common.constant.CommonConstant;
+import cn.com.poc.common.pool.CommonThreadPoolExecutor;
 import cn.com.poc.common.service.RedisService;
 import cn.com.poc.common.utils.BlContext;
 import cn.com.poc.common.utils.JsonUtils;
@@ -182,14 +183,14 @@ public class AgentApplicationServiceImpl implements AgentApplicationService {
         return result;
     }
 
+
     @Override
     public void createRecommendQuestion() throws InterruptedException {
         List<Object> questions = new CopyOnWriteArrayList<>();
-        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 5, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
         CountDownLatch countDownLatch = new CountDownLatch(20);
 
         for (int i = 0; i < 20; i++) {
-            threadPoolExecutor.execute(() -> {
+            CommonThreadPoolExecutor.addTask(() -> {
                 Message message = new Message();
                 message.setRole(AgentApplicationDialoguesRecordConstants.ROLE.USER);
                 MultiContent multiContent = new MultiContent();