From 654433b77ead4c47e5d2b3cd82c2f61509773b81 Mon Sep 17 00:00:00 2001 From: zren25 Date: Wed, 28 May 2025 15:41:12 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=93=AD=E7=89=8C=E7=9A=84?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/TmNameplateCorpusServiceImpl.java | 22 +++++++++---------- 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java index d3a8504..901cd05 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java @@ -110,18 +110,16 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl messageList = tmNameplateCorpusMapper.queryTmNameplateCorpusRetry(statTime, endTime, offset, pageSize, customerFlowIds, retry); - // 处理查询到的数据 - // 使用 CompletableFuture 并行处理 - CompletableFuture[] futures = messageList.stream() - .map(item -> CompletableFuture.runAsync(() -> { - try { - processItem(item); - } catch (Exception e) { - log.error("重跑铭牌语料失败: customerFlowId={}, AcceptUserId={}, 异常: {}", - item.getCustomerFlowId(), e.getMessage(), e); - } - }, executor)) - .toArray(CompletableFuture[]::new); + for(TmNameplateCorpus tmNameplateCorpus :messageList){ + CompletableFuture.runAsync(() -> { + try { + processItem(tmNameplateCorpus); + } catch (Exception e) { + log.error("重跑铭牌语料失败: customerFlowId={}, AcceptUserId={}, 异常: {}", + tmNameplateCorpus.getCustomerFlowId(), e.getMessage(), e); + } + }, executor); + } } log.info("重跑铭牌语料铭牌数据跑批结束 耗时：{}",System.currentTimeMillis()-startTime); }