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

!88 work线程池优化

Browse Source 
优化线程池，当work节点有重复批次任务的时候，再启动并行度。
修复jdk8客户端不兼容springboot2.0
This commit is contained in:
北极星 2024-09-07 05:43:14 +00:00 committed by opensnail
parent 16a6d8e778
commit 9bec12a27f
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,13 +24,20 @@ 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)) {
return CACHE_THREAD_POOL.get(taskBatchId); ThreadPoolExecutor threadPoolExecutor = CACHE_THREAD_POOL.get(taskBatchId);
if (threadPoolExecutor.getCorePoolSize() == parallelNum) {
return threadPoolExecutor;
} else {
threadPoolExecutor.setCorePoolSize(parallelNum);
threadPoolExecutor.setMaximumPoolSize(parallelNum);
}
return threadPoolExecutor;
} }
Supplier<ThreadPoolExecutor> supplier = () -> { Supplier<ThreadPoolExecutor> supplier = () -> {
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor( ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
parallelNum, parallelNum, 10, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), 1, 1, 10, TimeUnit.SECONDS, new LinkedBlockingQueue<>(),
new CustomizableThreadFactory(MessageFormat.format("snail-job-job-{0}-", taskBatchId))); new CustomizableThreadFactory(MessageFormat.format("snail-job-job-{0}-", taskBatchId)));
threadPoolExecutor.allowCoreThreadTimeOut(true); threadPoolExecutor.allowCoreThreadTimeOut(true);
return threadPoolExecutor; return threadPoolExecutor;