From 6235112c4b0f15136d78d97c94041887b003d6b4 Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Tue, 2 Sep 2025 11:32:21 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E8=B0=83=E6=95=B4=E6=A0=B8=E5=BF=83?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mall/shop/sync/listen/ShopBatchSubmitListener.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/sync/listen/ShopBatchSubmitListener.java b/mall-shop/src/main/java/com/suisung/mall/shop/sync/listen/ShopBatchSubmitListener.java
index ea6403a5..7c749ea0 100644
--- a/mall-shop/src/main/java/com/suisung/mall/shop/sync/listen/ShopBatchSubmitListener.java
+++ b/mall-shop/src/main/java/com/suisung/mall/shop/sync/listen/ShopBatchSubmitListener.java
@@ -57,9 +57,9 @@ public class ShopBatchSubmitListener extends AnalysisEventListener<SxGoosModelEx
         this.syncThirdDataService = syncThirdDataService;
         this.syncStoreSpecsService = syncStoreSpecsService;
         // 创建线程池（根据CPU核心数优化）
-        int corePoolSize = Runtime.getRuntime().availableProcessors();
+  //      int corePoolSize = Runtime.getRuntime().availableProcessors();
 //        log.info("核心线程数量{}", corePoolSize);
-        this.executorService = Executors.newFixedThreadPool(corePoolSize);
+        this.executorService = Executors.newFixedThreadPool(6);
         this.futures = new ArrayList<>();
         this.success = new AtomicInteger();
         this.fails = new AtomicInteger();