From 40f8243ec44e92ed1081d19dd0f418e60b49912c Mon Sep 17 00:00:00 2001
From: luoweijian <1329394916@qq.com>
Date: Sat, 21 Mar 2026 11:26:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=96=87=E6=A1=A3=E8=81=9A?=
 =?UTF-8?q?=E7=B1=BB=E5=AE=9E=E4=BD=93=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/SaveClusterDomainServiceImpl.java    |  2 +-
 .../impl/InitTaskDomainServiceImpl.java       | 22 ++++++++++++-------
 2 files changed, 15 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/project/interaction/domain/service/impl/SaveClusterDomainServiceImpl.java b/src/main/java/com/project/interaction/domain/service/impl/SaveClusterDomainServiceImpl.java
index 63bed00..1783ceb 100644
--- a/src/main/java/com/project/interaction/domain/service/impl/SaveClusterDomainServiceImpl.java
+++ b/src/main/java/com/project/interaction/domain/service/impl/SaveClusterDomainServiceImpl.java
@@ -83,7 +83,7 @@ public class SaveClusterDomainServiceImpl implements SaveClusterDomainService {
             // 批量插入
             knowledgePointBaseService.updateBatchById(kpList);
         }
-        Thread.sleep(60000);
+//        Thread.sleep(60000);
 
         InformationEntity byId = informationBaseService.getById(informationId);
         byId.setParseStatus(InformationParseStatusEnum.Success.getValue());
diff --git a/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java b/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
index bd73778..92fa336 100644
--- a/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
+++ b/src/main/java/com/project/task/domain/service/impl/InitTaskDomainServiceImpl.java
@@ -42,14 +42,20 @@ public class InitTaskDomainServiceImpl implements InitTaskDomainService {
 
     @Override
     public void asyncInitialize(Long taskId, List<Long> relatedDocIds) {
-        CompletableFuture.runAsync(() -> {
-            try {
-                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
-                handle(taskId, relatedDocIds);
-            } catch (Exception e) {
-                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
-            }
-        }, taskInternalExecutor);
+//        CompletableFuture.runAsync(() -> {
+//            try {
+//                log.info(">>> 收到考试任务[{}]初始化请求，开始异步处理...", taskId);
+//                handle(taskId, relatedDocIds);
+//            } catch (Exception e) {
+//                log.error(">>> 考试任务[{}]异步初始化过程发生严重异常", taskId, e);
+//            }
+//        }, taskInternalExecutor);
+        try {
+            log.info(">>> 收到考试任务[{}]初始化请求，开始同步处理...", taskId);
+            handle(taskId, relatedDocIds);
+        } catch (Exception e) {
+            log.error(">>> 考试任务[{}]同步初始化过程发生严重异常", taskId, e);
+        }
     }
 
     public void handle(Long taskId, List<Long> docIds) throws Exception {