From ada892157d8a957cfce82a8129ad1c0ccd3033ab Mon Sep 17 00:00:00 2001 From: srzou Date: Fri, 20 Sep 2024 16:38:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:(1.2.0-beta2):=20=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E8=8E=B7=E5=8F=96=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E6=97=B6=E7=9A=84=E5=B9=B6=E5=8F=91=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../snailjob/client/job/core/cache/ThreadPoolCache.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/cache/ThreadPoolCache.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/cache/ThreadPoolCache.java index f4649120d..fb1c384e9 100644 --- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/cache/ThreadPoolCache.java +++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/cache/ThreadPoolCache.java @@ -45,7 +45,11 @@ public class ThreadPoolCache { }; ThreadPoolExecutor threadPoolExecutor = supplier.get(); - CACHE_THREAD_POOL.putIfAbsent(taskBatchId, threadPoolExecutor); + ThreadPoolExecutor cacheThreadPoolExecutor = CACHE_THREAD_POOL.putIfAbsent(taskBatchId, threadPoolExecutor); + if (Objects.nonNull(cacheThreadPoolExecutor) && cacheThreadPoolExecutor != threadPoolExecutor) { + cacheThreadPoolExecutor.setCorePoolSize(Math.min(parallelNum, cacheThreadPoolExecutor.getMaximumPoolSize())); + return cacheThreadPoolExecutor; + } return threadPoolExecutor; }