From 0a68e52fcac1f81c7c8250f1547b3f8433959e27 Mon Sep 17 00:00:00 2001 From: huanghongxun Date: Thu, 20 Feb 2020 14:06:03 +0800 Subject: [PATCH] fix: tasks with default name will not be displayed --- .../jackhuang/hmcl/game/LauncherHelper.java | 14 ++++++------- .../jackhuang/hmcl/download/VersionList.java | 2 +- .../java/org/jackhuang/hmcl/task/Task.java | 21 ++++++++++--------- 3 files changed, 19 insertions(+), 18 deletions(-) diff --git a/HMCL/src/main/java/org/jackhuang/hmcl/game/LauncherHelper.java b/HMCL/src/main/java/org/jackhuang/hmcl/game/LauncherHelper.java index a8a7e976d..d33681b0f 100644 --- a/HMCL/src/main/java/org/jackhuang/hmcl/game/LauncherHelper.java +++ b/HMCL/src/main/java/org/jackhuang/hmcl/game/LauncherHelper.java @@ -128,12 +128,12 @@ public final class LauncherHelper { Optional gameVersion = GameVersion.minecraftVersion(repository.getVersionJar(version)); TaskExecutor executor = Task.allOf( - Task.composeAsync(null, () -> { + Task.composeAsync(() -> { if (setting.isNotCheckGame()) return null; else return dependencyManager.checkGameCompletionAsync(version, repository.unmarkVersionLaunchedAbnormally(selectedVersion)); - }), Task.composeAsync(null, () -> { + }), Task.composeAsync(() -> { try { ModpackConfiguration configuration = ModpackHelper.readModpackConfiguration(repository.getModpackConfiguration(selectedVersion)); if ("Curse".equals(configuration.getType())) @@ -146,7 +146,7 @@ public final class LauncherHelper { return null; } })).withStage("launch.state.dependencies") - .thenComposeAsync(Task.supplyAsync((String) null, () -> { + .thenComposeAsync(Task.supplyAsync(() -> { try { return account.logIn(); } catch (CredentialExpiredException e) { @@ -157,7 +157,7 @@ public final class LauncherHelper { return account.playOffline().orElseThrow(() -> e); } }).withStage("launch.state.logging_in")) - .thenComposeAsync(authInfo -> Task.supplyAsync((String) null, () -> { + .thenComposeAsync(authInfo -> Task.supplyAsync(() -> { return new HMCLGameLauncher( repository, version.getPatches().isEmpty() ? repository.getResolvedVersion(selectedVersion) : version, @@ -169,9 +169,9 @@ public final class LauncherHelper { ); }).thenComposeAsync(launcher -> { // launcher is prev task's result if (scriptFile == null) { - return Task.supplyAsync((String) null, launcher::launch); + return Task.supplyAsync(launcher::launch); } else { - return Task.supplyAsync((String) null, () -> { + return Task.supplyAsync(() -> { launcher.makeLaunchScript(scriptFile); return null; }); @@ -192,7 +192,7 @@ public final class LauncherHelper { Controllers.dialog(i18n("version.launch_script.success", scriptFile.getAbsolutePath())); }); } - }).thenRunAsync(null, Schedulers.defaultScheduler(), () -> { + }).thenRunAsync(Schedulers.defaultScheduler(), () -> { launchingLatch = new CountDownLatch(1); launchingLatch.await(); }).withStage("launch.state.waiting_launching")) diff --git a/HMCLCore/src/main/java/org/jackhuang/hmcl/download/VersionList.java b/HMCLCore/src/main/java/org/jackhuang/hmcl/download/VersionList.java index 647dec2a3..4f2378566 100644 --- a/HMCLCore/src/main/java/org/jackhuang/hmcl/download/VersionList.java +++ b/HMCLCore/src/main/java/org/jackhuang/hmcl/download/VersionList.java @@ -86,7 +86,7 @@ public abstract class VersionList { } public Task loadAsync(String gameVersion) { - return Task.composeAsync(null, () -> { + return Task.composeAsync(() -> { lock.readLock().lock(); boolean loaded; diff --git a/HMCLCore/src/main/java/org/jackhuang/hmcl/task/Task.java b/HMCLCore/src/main/java/org/jackhuang/hmcl/task/Task.java index 0c02c9e27..3ab6383d2 100644 --- a/HMCLCore/src/main/java/org/jackhuang/hmcl/task/Task.java +++ b/HMCLCore/src/main/java/org/jackhuang/hmcl/task/Task.java @@ -63,8 +63,9 @@ public abstract class Task { return significance; } - public final void setSignificance(TaskSignificance significance) { + public final Task setSignificance(TaskSignificance significance) { this.significance = significance; + return this; } // cancel @@ -419,7 +420,7 @@ public abstract class Task { * @return the new Task */ public Task thenApplyAsync(Executor executor, ExceptionalFunction fn) { - return thenApplyAsync(getCaller(), executor, fn); + return thenApplyAsync(getCaller(), executor, fn).setSignificance(TaskSignificance.MODERATE); } /** @@ -460,7 +461,7 @@ public abstract class Task { * @return the new Task */ public Task thenAcceptAsync(Executor executor, ExceptionalConsumer action) { - return thenAcceptAsync(getCaller(), executor, action); + return thenAcceptAsync(getCaller(), executor, action).setSignificance(TaskSignificance.MODERATE); } /** @@ -502,7 +503,7 @@ public abstract class Task { * @return the new Task */ public Task thenRunAsync(Executor executor, ExceptionalRunnable action) { - return thenRunAsync(getCaller(), executor, action); + return thenRunAsync(getCaller(), executor, action).setSignificance(TaskSignificance.MODERATE); } /** @@ -614,7 +615,7 @@ public abstract class Task { * @return the new Task */ public Task withRunAsync(Executor executor, ExceptionalRunnable action) { - return withRunAsync(getCaller(), executor, action); + return withRunAsync(getCaller(), executor, action).setSignificance(TaskSignificance.MODERATE); } /** @@ -701,7 +702,7 @@ public abstract class Task { public List getStages() { return Lang.merge(Task.this.getStages(), super.getStages()); } - }.setExecutor(executor).setName(getCaller()); + }.setExecutor(executor).setName(getCaller()).setSignificance(TaskSignificance.MODERATE); } /** @@ -810,7 +811,7 @@ public abstract class Task { } public static Task runAsync(Executor executor, ExceptionalRunnable closure) { - return runAsync(getCaller(), executor, closure); + return runAsync(getCaller(), executor, closure).setSignificance(TaskSignificance.MODERATE); } public static Task runAsync(String name, Executor executor, ExceptionalRunnable closure) { @@ -818,7 +819,7 @@ public abstract class Task { } public static Task composeAsync(ExceptionalSupplier, ?> fn) { - return composeAsync(getCaller(), fn); + return composeAsync(getCaller(), fn).setSignificance(TaskSignificance.MODERATE); } public static Task composeAsync(String name, ExceptionalSupplier, ?> fn) { @@ -845,11 +846,11 @@ public abstract class Task { } public static Task supplyAsync(Callable callable) { - return supplyAsync(getCaller(), callable); + return supplyAsync(getCaller(), callable).setSignificance(TaskSignificance.MODERATE); } public static Task supplyAsync(Executor executor, Callable callable) { - return supplyAsync(getCaller(), executor, callable); + return supplyAsync(getCaller(), executor, callable).setSignificance(TaskSignificance.MODERATE); } public static Task supplyAsync(String name, Callable callable) {