From 39970847c624e41f12879f1491c5f57e37ca7d46 Mon Sep 17 00:00:00 2001
From: fantasticbin <fantasticbin@vip.qq.com>
Date: Tue, 3 Dec 2024 10:32:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=BB=B6=E8=BF=9F=E6=97=A0?=
 =?UTF-8?q?=E9=94=81=E9=98=9F=E5=88=97=E4=B8=AD=E7=9A=84=E6=8C=81=E7=BB=AD?=
 =?UTF-8?q?=E7=9B=91=E5=90=AC=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lock_free/delay_queue.go | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/lock_free/delay_queue.go b/lock_free/delay_queue.go
index 64d3f8d..2531aee 100644
--- a/lock_free/delay_queue.go
+++ b/lock_free/delay_queue.go
@@ -21,13 +21,12 @@ func (q *DelayLkQueue[T]) DelayEnqueue(value T, duration time.Duration) {
 // ContinuousDequeue 持续监听出队通知
 func (q *DelayLkQueue[T]) ContinuousDequeue(notify ...chan T) {
 	for {
-		value, ok := q.Dequeue()
-		if !ok {
+		if value, ok := q.Dequeue(); ok {
+			for _, n := range notify {
+				n <- value
+			}
+		} else {
 			time.Sleep(time.Millisecond) // 队列为空，休眠1毫秒
-			continue
-		}
-		for _, n := range notify {
-			n <- value
 		}
 	}
 }