diff --git a/core/deployment/src/main/java/io/quarkus/deployment/console/AeshConsole.java b/core/deployment/src/main/java/io/quarkus/deployment/console/AeshConsole.java index c881b28d12b3f..320ee08e30de8 100644 --- a/core/deployment/src/main/java/io/quarkus/deployment/console/AeshConsole.java +++ b/core/deployment/src/main/java/io/quarkus/deployment/console/AeshConsole.java @@ -6,7 +6,7 @@ import java.util.HashMap; import java.util.Map; import java.util.TreeMap; -import java.util.concurrent.LinkedBlockingDeque; +import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantLock; @@ -56,7 +56,7 @@ public class AeshConsole extends QuarkusConsole { * Because Aesh can log deadlocks are possible on Windows if a write fails, unless care * is taken. */ - private final LinkedBlockingDeque writeQueue = new LinkedBlockingDeque<>(); + private final ConcurrentLinkedQueue writeQueue = new ConcurrentLinkedQueue<>(); private final Lock connectionLock = new ReentrantLock(); private static final ThreadLocal IN_WRITE = new ThreadLocal<>() { @Override