From f54388efa84df422f6f82a9ff244ffd3436a59ba Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Wed, 29 Mar 2023 16:35:51 +0200 Subject: [PATCH] Fix name --- src/main/java/it/cavallium/dbengine/utils/StreamUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/it/cavallium/dbengine/utils/StreamUtils.java b/src/main/java/it/cavallium/dbengine/utils/StreamUtils.java index bf04b97..384685a 100644 --- a/src/main/java/it/cavallium/dbengine/utils/StreamUtils.java +++ b/src/main/java/it/cavallium/dbengine/utils/StreamUtils.java @@ -59,13 +59,13 @@ public class StreamUtils { private static final Function FINISHER = x -> null; private static final Collector SUMMING_LONG_COLLECTOR = new SummingLongCollector(); - public static ForkJoinPool newNamedForkJoinPool(String name, boolean fifo) { + public static ForkJoinPool newNamedForkJoinPool(String name, boolean async) { final int MAX_CAP = 0x7fff; // max #workers - 1 return new ForkJoinPool( Math.min(MAX_CAP, Runtime.getRuntime().availableProcessors()), new NamedForkJoinWorkerThreadFactory(name), null, - fifo, + async, 0, MAX_CAP, 1,