Fix the wait condition

amarziali · amarziali · commit 24d5444e526a · 2025-11-07T15:45:10.000+01:00
diff --git a/internal-api/internal-api-9/src/main/java/datadog/trace/util/queue/MpscBlockingConsumerArrayQueueVarHandle.java b/internal-api/internal-api-9/src/main/java/datadog/trace/util/queue/MpscBlockingConsumerArrayQueueVarHandle.java
@@ -43,7 +43,7 @@ public boolean offer(E e) {
   public E take() throws InterruptedException {
     consumerThread = Thread.currentThread();
     E e;
-    while ((e = poll()) != null) {
+    while ((e = poll()) == null) {
       parkUntilNext(-1);
     }
     return e;

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ public boolean offer(E e) {`
`43`	`43`	`public E take() throws InterruptedException {`
`44`	`44`	`consumerThread = Thread.currentThread();`
`45`	`45`	`E e;`
`46`		`- while ((e = poll()) != null) {`
	`46`	`+ while ((e = poll()) == null) {`
`47`	`47`	`parkUntilNext(-1);`
`48`	`48`	`}`
`49`	`49`	`return e;`