getrebuild/rebuild
1
1
Fork 0
mirror of https://github.com/getrebuild/rebuild.git synced 2024-09-20 23:45:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: #207

Browse source
This commit is contained in:
oahzeved 2020-08-13 15:48:48 +08:00
parent d32958a6ed
commit 99cecf4795
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/main/java/com/rebuild/server/helper/task/TaskExecutors.java
View file

@ -37,13 +37,12 @@ public class TaskExecutors extends QuartzJobBean {
private static final Log LOG = LogFactory.getLog(TaskExecutors.class);
private static final int MAX_TASK = Runtime.getRuntime().availableProcessors() / 2;
private static final int MAX_QUEUE = MAX_TASK * 10;
private static final int MAX_TASKS_NUMBER = Integer.max(Runtime.getRuntime().availableProcessors() / 2, 2);
private static final ExecutorService EXECS = new ThreadPoolExecutor(
MAX_TASK, MAX_TASK, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(MAX_QUEUE));
MAX_TASKS_NUMBER, MAX_TASKS_NUMBER, 0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(MAX_TASKS_NUMBER * 10));
private static final Map<String, HeavyTask<?>> TASKS = new ConcurrentHashMap<>();
/**