diff --git a/lock_free/queues.go b/lock_free/queues.go index 5db1ff8..5a2d5f9 100644 --- a/lock_free/queues.go +++ b/lock_free/queues.go @@ -1,7 +1,6 @@ package lock_free import ( - "fmt" "iter" "sync" "time" @@ -84,7 +83,6 @@ func (q *Queues[TKey, TValue, TRoute]) makeAckData(route TRoute, value TValue, v case <-time.After(q.expireAutoFail): // 重新入队 - fmt.Println("ack timeout") queue.(*DelayLkQueue[TKey, TValue]).Enqueue(value) } }