1

2024-04-26 13:24:04 +08:00 · 2024-04-26 13:24:04 +08:00 · 4f7255c731
commit 4f7255c731
parent 0ec6d9a142
1 changed files with 9 additions and 0 deletions
--- a/queue.go
+++ b/queue.go
@ -30,3 +30,12 @@ func (this *Queue) Fetch() {
 		}
 	}
 }
+
+func (this *Queue) IsEmpty() bool {
+	if !this.WorkList.Empty() {
+		return false
+	}
+	this.msgMutex.Lock()
+	defer this.msgMutex.Unlock()
+	return this.msgList.Empty()
+}