diff --git a/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/PlatformDependent.java b/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/PlatformDependent.java index ec827d62ea..831b4013c2 100644 --- a/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/PlatformDependent.java +++ b/servicetalk-utils-internal/src/main/java/io/servicetalk/utils/internal/PlatformDependent.java @@ -316,9 +316,9 @@ static Queue newMpscQueue(final int initialCapacity, final int maxCapacit } static Queue newUnboundedMpscQueue(final int initialCapacity) { - return USE_UNSAFE_QUEUES ? new MpscUnboundedUnpaddedArrayQueue<>(max(MIN_ALLOWED_MPSC_CHUNK_SIZE, initialCapacity)) - : new MpscUnboundedAtomicArrayQueue<>( - max(MIN_ALLOWED_MPSC_CHUNK_SIZE, initialCapacity)); + return USE_UNSAFE_QUEUES ? + new MpscUnboundedUnpaddedArrayQueue<>(max(MIN_ALLOWED_MPSC_CHUNK_SIZE, initialCapacity)) : + new MpscUnboundedAtomicArrayQueue<>(max(MIN_ALLOWED_MPSC_CHUNK_SIZE, initialCapacity)); } static Queue newUnboundedLinkedMpscQueue() {