drain not take

Signed-off-by: Ceki Gulcu <ceki@qos.ch>
qos-ch · Aug 19, 2021 · 2c9348a · 2c9348a
1 parent bb57bee
commit 2c9348a
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/logback-core/src/main/java/ch/qos/logback/core/AsyncAppenderBase.java b/logback-core/src/main/java/ch/qos/logback/core/AsyncAppenderBase.java
@@ -17,7 +17,9 @@
 import ch.qos.logback.core.spi.AppenderAttachableImpl;
 import ch.qos.logback.core.util.InterruptUtil;
 
+import java.util.ArrayList;
 import java.util.Iterator;
+import java.util.List;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 
@@ -287,11 +289,10 @@ public void run() {
 
             // loop while the parent is started
             while (parent.isStarted()) {
-                try {
-                    E e = parent.blockingQueue.take();
-                    aai.appendLoopOnAppenders(e);
-                } catch (InterruptedException ie) {
-                    break;
+                List<E> elements = new ArrayList<E>();
+                parent.blockingQueue.drainTo(elements);
+                for(E e: elements) {
+                   aai.appendLoopOnAppenders(e);
                 }
             }