fantasticbin/go-study
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

完善队列集合的ACK确认机制

Browse Source
This commit is contained in:
fantasticbin 2024-12-10 12:52:22 +08:00
parent 1647f91ba4
commit f290e7dd0c
1 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lock_free/queues.go
View File

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