Skip to content

Commit 69ec7b0

Browse files
committed
Wrapped TaskExecutor's thread pool.
1 parent cf6dc94 commit 69ec7b0

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/github/kasuminova/mmce/common/concurrent/TaskExecutor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
public class TaskExecutor {
2121
public static final int THREAD_COUNT = Math.max(Math.max(Runtime.getRuntime().availableProcessors() / 4, 8), 4);
2222

23-
public static final ThreadPoolExecutor THREAD_POOL = new ThreadPoolExecutor(
23+
private static final ThreadPoolExecutor THREAD_POOL = new ThreadPoolExecutor(
2424
THREAD_COUNT / 4, THREAD_COUNT, 5000, TimeUnit.MILLISECONDS,
2525
new PriorityBlockingQueue<>(),
2626
new CustomThreadFactory("MMCE-TaskExecutor-%s"));
@@ -143,7 +143,7 @@ public ActionExecutor addParallelAsyncTask(final Action action) {
143143
/**
144144
* <p>添加一个并行异步操作引用,这个操作必定在本 Tick 结束前执行完毕。</p>
145145
*
146-
* @param action 要执行的异步任务
146+
* @param action 要执行的异步任务
147147
* @param priority 优先级
148148
*/
149149
public ActionExecutor addParallelAsyncTask(final Action action, final int priority) {

src/main/java/hellfirepvp/modularmachinery/common/CommonProxy.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ public ItemStack createIcon() {
129129
MinecraftForge.EVENT_BUS.register(ModularMachinery.EXECUTE_MANAGER);
130130
ModularMachinery.EXECUTE_MANAGER.init();
131131
checkThirdPartyServer();
132-
ModularMachinery.log.info(String.format("[ModularMachinery-CE] Parallel executor is ready (%s Threads), Let's get started!!!", TaskExecutor.THREAD_POOL.getMaximumPoolSize()));
132+
ModularMachinery.log.info(String.format("[ModularMachinery-CE] Parallel executor is ready (%s Threads), Let's get started!!!", TaskExecutor.THREAD_COUNT));
133133
}
134134

135135
public void init() {

0 commit comments

Comments
 (0)