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

work线程池优化

Browse Source
This commit is contained in:
1115900427@qq.com 2024-09-06 21:25:28 +08:00
parent eb2bc63240
commit 1e0f6a88a0
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -25,8 +25,12 @@ public class ThreadPoolCache {
public static ThreadPoolExecutor createThreadPool(Long taskBatchId, int parallelNum) { public static ThreadPoolExecutor createThreadPool(Long taskBatchId, int parallelNum) {
if (CACHE_THREAD_POOL.containsKey(taskBatchId)) { if (CACHE_THREAD_POOL.containsKey(taskBatchId)) {
ThreadPoolExecutor threadPoolExecutor = CACHE_THREAD_POOL.get(taskBatchId); ThreadPoolExecutor threadPoolExecutor = CACHE_THREAD_POOL.get(taskBatchId);
threadPoolExecutor.setCorePoolSize(parallelNum); if (threadPoolExecutor.getCorePoolSize() == parallelNum) {
threadPoolExecutor.setMaximumPoolSize(parallelNum); return threadPoolExecutor;
} else {
threadPoolExecutor.setCorePoolSize(parallelNum);
threadPoolExecutor.setMaximumPoolSize(parallelNum);
}
return threadPoolExecutor; return threadPoolExecutor;
} }