Skip to content

Commit b4fc147

Browse files
committed
Remove unneccesarry timestamp
1 parent 6921fe7 commit b4fc147

File tree

1 file changed

+8
-14
lines changed

1 file changed

+8
-14
lines changed

pkg/controller/priorityqueue/priorityqueue.go

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -135,11 +135,10 @@ func (w *priorityqueue[T]) AddWithOpts(o AddOpts, items ...T) {
135135
}
136136
if _, ok := w.items[key]; !ok {
137137
item := &item[T]{
138-
key: key,
139-
addedAtUnixNano: w.now().UnixNano(),
140-
addedCounter: w.addedCounter,
141-
priority: o.Priority,
142-
readyAt: readyAt,
138+
key: key,
139+
addedCounter: w.addedCounter,
140+
priority: o.Priority,
141+
readyAt: readyAt,
143142
}
144143
w.items[key] = item
145144
w.queue.ReplaceOrInsert(item)
@@ -305,19 +304,14 @@ func less[T comparable](a, b *item[T]) bool {
305304
return a.priority > b.priority
306305
}
307306

308-
if a.addedAtUnixNano != b.addedAtUnixNano {
309-
return a.addedAtUnixNano < b.addedAtUnixNano
310-
}
311-
312307
return a.addedCounter < b.addedCounter
313308
}
314309

315310
type item[T comparable] struct {
316-
key T
317-
addedAtUnixNano int64
318-
addedCounter uint64
319-
priority int
320-
readyAt *time.Time
311+
key T
312+
addedCounter uint64
313+
priority int
314+
readyAt *time.Time
321315
}
322316

323317
func (w *priorityqueue[T]) updateUnfinishedWorkLoop() {

0 commit comments

Comments
 (0)