diff options
-rw-r--r-- | queue.go | 3 |
1 files changed, 0 insertions, 3 deletions
@@ -244,9 +244,6 @@ func (q *Queue[K]) Pop() (item Item[K], ok bool) { q.snoozeQ.Push(key, time.Now().Add(q.interval()).UnixMicro()) q.snoozeQNotEmpty.Signal() } else { - q.partitionsMu.Lock() - delete(q.partitions, key) - q.partitionsMu.Unlock() q.inactiveKeys[key] = time.Now().Add(q.interval()) } q.snoozeQMu.Unlock() |