diff options
| author | shedaniel <daniel@shedaniel.me> | 2021-10-04 02:14:46 +0800 |
|---|---|---|
| committer | shedaniel <daniel@shedaniel.me> | 2021-10-04 02:14:46 +0800 |
| commit | 5582887ee7bf644136c2a32b64f0625d31986b3c (patch) | |
| tree | b0ed4cdc196cefc038c7cd32881ae92e30985e37 /src/main/java | |
| parent | d71745f318920b3f590d3d3e91a0841b4514a9db (diff) | |
| download | architectury-loom-5582887ee7bf644136c2a32b64f0625d31986b3c.tar.gz architectury-loom-5582887ee7bf644136c2a32b64f0625d31986b3c.tar.bz2 architectury-loom-5582887ee7bf644136c2a32b64f0625d31986b3c.zip | |
Fix java.lang.IllegalArgumentException in ThreadingUtils
Signed-off-by: shedaniel <daniel@shedaniel.me>
Diffstat (limited to 'src/main/java')
| -rw-r--r-- | src/main/java/net/fabricmc/loom/util/ThreadingUtils.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/net/fabricmc/loom/util/ThreadingUtils.java b/src/main/java/net/fabricmc/loom/util/ThreadingUtils.java index d79f5fa4..d6d06f79 100644 --- a/src/main/java/net/fabricmc/loom/util/ThreadingUtils.java +++ b/src/main/java/net/fabricmc/loom/util/ThreadingUtils.java @@ -58,7 +58,7 @@ public class ThreadingUtils { public static void run(Collection<UnsafeRunnable> jobs) { try { - ExecutorService service = Executors.newFixedThreadPool(Math.min(jobs.size(), Runtime.getRuntime().availableProcessors() / 2)); + ExecutorService service = Executors.newFixedThreadPool(Math.max(1, Math.min(jobs.size(), Runtime.getRuntime().availableProcessors()))); List<Future<?>> futures = new LinkedList<>(); for (UnsafeRunnable runnable : jobs) { @@ -94,7 +94,7 @@ public class ThreadingUtils { public static <T> List<T> get(Collection<UnsafeCallable<T>> jobs) { try { - ExecutorService service = Executors.newFixedThreadPool(Math.min(jobs.size(), Runtime.getRuntime().availableProcessors() / 2)); + ExecutorService service = Executors.newFixedThreadPool(Math.max(1, Math.min(jobs.size(), Runtime.getRuntime().availableProcessors()))); List<Future<T>> futures = new LinkedList<>(); List<T> result = new ArrayList<>(); @@ -138,7 +138,7 @@ public class ThreadingUtils { public static class TaskCompleter implements Function<Throwable, Void> { Stopwatch stopwatch = Stopwatch.createUnstarted(); List<CompletableFuture<?>> tasks = new ArrayList<>(); - ExecutorService service = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); + ExecutorService service = Executors.newFixedThreadPool(Math.max(1, Runtime.getRuntime().availableProcessors())); List<UnsafeConsumer<Stopwatch>> completionListener = new ArrayList<>(); public TaskCompleter add(UnsafeRunnable job) { |