backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix:调整核心线程数

Browse Source
This commit is contained in:
liyj 2025-09-02 11:32:21 +08:00
parent 5dcfa60056
commit 6235112c4b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mall-shop/src/main/java/com/suisung/mall/shop/sync/listen/ShopBatchSubmitListener.java
View File

@ -57,9 +57,9 @@ public class ShopBatchSubmitListener extends AnalysisEventListener<SxGoosModelEx
this.syncThirdDataService = syncThirdDataService; this.syncThirdDataService = syncThirdDataService;
this.syncStoreSpecsService = syncStoreSpecsService; this.syncStoreSpecsService = syncStoreSpecsService;
// 创建线程池（根据CPU核心数优化） // 创建线程池（根据CPU核心数优化）
int corePoolSize = Runtime.getRuntime().availableProcessors(); // int corePoolSize = Runtime.getRuntime().availableProcessors();
// log.info("核心线程数量{}", corePoolSize); // log.info("核心线程数量{}", corePoolSize);
this.executorService = Executors.newFixedThreadPool(corePoolSize); this.executorService = Executors.newFixedThreadPool(6);
this.futures = new ArrayList<>(); this.futures = new ArrayList<>();
this.success = new AtomicInteger(); this.success = new AtomicInteger();
this.fails = new AtomicInteger(); this.fails = new AtomicInteger();