This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch branch-4.15 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/branch-4.15 by this push: new e536d23947 Switch back ordered executor to LinkedBlockingQueue (#3384) e536d23947 is described below commit e536d23947dfa6a34f976561f19e9c22b2e0410d Author: Matteo Merli <mme...@apache.org> AuthorDate: Fri Jul 22 09:50:56 2022 -0700 Switch back ordered executor to LinkedBlockingQueue (#3384) --- .../main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java b/bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java index c58f794f02..ded0f36a2f 100644 --- a/bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java +++ b/bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java @@ -36,6 +36,7 @@ import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; +import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; @@ -45,7 +46,6 @@ import java.util.stream.Collectors; import lombok.extern.slf4j.Slf4j; import org.apache.bookkeeper.common.collections.BlockingMpscQueue; -import org.apache.bookkeeper.common.collections.GrowableArrayBlockingQueue; import org.apache.bookkeeper.common.util.affinity.CpuAffinity; import org.apache.bookkeeper.stats.Gauge; import org.apache.bookkeeper.stats.NullStatsLogger; @@ -305,7 +305,7 @@ public class OrderedExecutor implements ExecutorService { queue = new BlockingMpscQueue<>(maxTasksInQueue > 0 ? maxTasksInQueue : DEFAULT_MAX_ARRAY_QUEUE_SIZE); } else { // By default, use regular JDK LinkedBlockingQueue - queue = new GrowableArrayBlockingQueue<>(); + queue = new LinkedBlockingQueue<>(); } return new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, queue, factory); }