fix(queue): fix deadlock conditional when Close()

Cleverse · Oct 23, 2023 · fedfe6d · fedfe6d
1 parent 89774b3
commit fedfe6d
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/queue/queue.go b/queue/queue.go
@@ -76,11 +76,10 @@ func (q *Queue[T]) Dequeue() (val T, ok bool) {
 	q.mu.Lock()
 	defer q.mu.Unlock()
 
-	if q.isClosed {
-		return val, false
-	}
-
 	for len(q.items) == 0 {
+		if q.isClosed {
+			return val, false
+		}
 		q.cond.Wait()
 	}