aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--queue.go3
1 files changed, 0 insertions, 3 deletions
diff --git a/queue.go b/queue.go
index 04eaef7..3d61ec3 100644
--- a/queue.go
+++ b/queue.go
@@ -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()