From 7855954497ea5482c25231696c5222a886ad00cb Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Fri, 19 Sep 2025 12:44:58 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97=20=20?= =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E9=AB=98=E6=B6=88=E8=B4=B9=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../volvo/ai/analytic/center/config/ExecutorConfig.java | 2 +- .../ai/analytic/center/mq/NameplateKafkaConsumer.java | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java index 1cbf197..373adc4 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java @@ -24,7 +24,7 @@ public class ExecutorConfig { private int maxPoolSize=12; // @Value("${task.pool.keepAliveSeconds}") - private int keepAliveSeconds=12000; + private int keepAliveSeconds=6000000; // @Value("${task.pool.queueCapacity}") private int queueCapacity=20; diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java index 2a7f14d..b0467c6 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java @@ -41,7 +41,7 @@ public class NameplateKafkaConsumer { @Autowired @Resource(name = "threadPoolTaskExecutor") private ThreadPoolTaskExecutor executor; - private Semaphore semaphore = new Semaphore(2); // 限制并发数 + private Semaphore semaphore = new Semaphore(10); // 限制并发数 @KafkaListener(topics = "${analyticCenterKafka.consumer.topic}", // = smart_assistant_nameplate_topic groupId = "${analyticCenterKafka.consumer.group}" , //smart_assistant_nameplate_topic_group @@ -70,14 +70,17 @@ public class NameplateKafkaConsumer { try { log.info(String.format("尝试获取许可，当前可用许可数: %d", semaphore.availablePermits())); + if (semaphore.availablePermits() == 0) + log.info("获取许可 失败，❌ 任务被中断"); semaphore.acquire(); // 获取许可 - log.info(String.format("获取许可后，当前可用许可数:: %d", + log.info(String.format("获取许可✅ 成功后，当前可用许可数:: %d", semaphore.availablePermits())); tmNameplateCorpusService.processItem(nameplate); } catch (Exception e) { log.error("corpusPortrait画像铭牌异步任务执行失败", e); } finally { log.info("corpusPortrait 释放锁，availablePermits {}", semaphore.availablePermits()); + semaphore.release(); // 释放许可 } }, executor));