diff --git a/jetty-io/src/main/java/org/eclipse/jetty/io/ByteBufferPool.java b/jetty-io/src/main/java/org/eclipse/jetty/io/ByteBufferPool.java index e752453475ee..2c67e29fdc6a 100644 --- a/jetty-io/src/main/java/org/eclipse/jetty/io/ByteBufferPool.java +++ b/jetty-io/src/main/java/org/eclipse/jetty/io/ByteBufferPool.java @@ -15,9 +15,9 @@ import java.nio.ByteBuffer; import java.util.ArrayList; -import java.util.Deque; import java.util.List; -import java.util.concurrent.ConcurrentLinkedDeque; +import java.util.Queue; +import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import java.util.function.Consumer; @@ -149,7 +149,7 @@ public void release(ByteBuffer buffer) public static class Bucket { - private final Deque _queue = new ConcurrentLinkedDeque<>(); + private final Queue _queue = new ConcurrentLinkedQueue<>(); private final int _capacity; private final int _maxSize; private final AtomicInteger _size; @@ -209,7 +209,7 @@ void clear(Consumer memoryFn) private void queueOffer(ByteBuffer buffer) { - _queue.offerFirst(buffer); + _queue.offer(buffer); } private ByteBuffer queuePoll()