lan/HMCL
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: executor service

Browse Source
This commit is contained in:
huanghongxun
2020-12-19 20:19:46 +08:00
parent 5e8734aa95
commit a828896989
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -51,7 +51,7 @@ public abstract class FetchTask<T> extends Task<T> {
this.urls = new ArrayList<>(urls); this.urls = new ArrayList<>(urls);
this.retry = retry; this.retry = retry;
setExecutor(Schedulers.io()); setExecutor(download());
} }
public void setCaching(boolean caching) { public void setCaching(boolean caching) {
@@ -278,7 +278,8 @@ public abstract class FetchTask<T> extends Task<T> {
if (DOWNLOAD_EXECUTOR == null) { if (DOWNLOAD_EXECUTOR == null) {
synchronized (Schedulers.class) { synchronized (Schedulers.class) {
if (DOWNLOAD_EXECUTOR == null) { if (DOWNLOAD_EXECUTOR == null) {
DOWNLOAD_EXECUTOR = new ThreadPoolExecutor(0, downloadExecutorConcurrency, 10, TimeUnit.SECONDS, new SynchronousQueue<>(), DOWNLOAD_EXECUTOR = new ThreadPoolExecutor(0, downloadExecutorConcurrency, 10, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(),
runnable -> { runnable -> {
Thread thread = Executors.defaultThreadFactory().newThread(runnable); Thread thread = Executors.defaultThreadFactory().newThread(runnable);
thread.setDaemon(true); thread.setDaemon(true);

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

@@ -47,7 +47,8 @@ public final class Schedulers {
if (IO_EXECUTOR == null) { if (IO_EXECUTOR == null) {
synchronized (Schedulers.class) { synchronized (Schedulers.class) {
if (IO_EXECUTOR == null) { if (IO_EXECUTOR == null) {
IO_EXECUTOR = new ThreadPoolExecutor(0, 4, 10, TimeUnit.SECONDS, new SynchronousQueue<>(), IO_EXECUTOR = new ThreadPoolExecutor(0, 4, 10, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(),
runnable -> { runnable -> {
Thread thread = Executors.defaultThreadFactory().newThread(runnable); Thread thread = Executors.defaultThreadFactory().newThread(runnable);
thread.setDaemon(true); thread.setDaemon(true);