AstralTransRocketries/HMCL
1
0
Fork 0
mirror of https://github.com/HMCL-dev/HMCL.git synced 2025-09-12 21:36:21 -04:00
Code Issues Packages Projects Releases Wiki Activity

try to fix RejectedExecutionException

Browse Source
This commit is contained in:
huangyuhui 2018-02-25 11:10:31 +08:00
parent 40360cf18a
commit 13a24d5b00
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
HMCLCore/src/main/java/org/jackhuang/hmcl/task/SchedulerExecutorService.java
View File

@ -36,7 +36,10 @@ class SchedulerExecutorService extends Scheduler {
@Override @Override
public Future<?> schedule(ExceptionalRunnable<?> block) { public Future<?> schedule(ExceptionalRunnable<?> block) {
return executorService.submit(block.toCallable()); if (executorService.isShutdown() || executorService.isTerminated())
return Schedulers.NONE.schedule(block);
else
return executorService.submit(block.toCallable());
} }
} }

4
HMCLCore/src/main/java/org/jackhuang/hmcl/task/Schedulers.java
View File

@ -17,6 +17,8 @@
*/ */
package org.jackhuang.hmcl.task; package org.jackhuang.hmcl.task;
import org.jackhuang.hmcl.util.Constants;
import java.util.concurrent.*; import java.util.concurrent.*;
/** /**
@ -112,6 +114,8 @@ public final class Schedulers {
return newThread(); return newThread();
} }
static final Scheduler NONE = new SchedulerImpl(Constants.emptyConsumer());
public static synchronized void shutdown() { public static synchronized void shutdown() {
if (CACHED_EXECUTOR != null) if (CACHED_EXECUTOR != null)
CACHED_EXECUTOR.shutdown(); CACHED_EXECUTOR.shutdown();