gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

fix:(1.2.0-beta2): 修复客户端获取线程时的并发问题

Browse Source
This commit is contained in:
srzou 2024-09-20 16:38:29 +08:00
parent 580686dd6b
commit ada892157d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/cache/ThreadPoolCache.java vendored
View File

@ -45,7 +45,11 @@ public class ThreadPoolCache {
}; };
ThreadPoolExecutor threadPoolExecutor = supplier.get(); 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; return threadPoolExecutor;
} }