()
| 53 | } |
| 54 | |
| 55 | func (t *TimePriorityQueue[T]) GetAll() []T { |
| 56 | t.tqueue.mu.Lock() |
| 57 | defer t.tqueue.mu.Unlock() |
| 58 | res := make([]T, 0, t.tqueue.heap.Len()+t.ready.Len()) |
| 59 | for _, entry := range t.tqueue.heap { |
| 60 | res = append(res, entry.v.v) |
| 61 | } |
| 62 | for _, entry := range t.ready { |
| 63 | res = append(res, entry.v) |
| 64 | } |
| 65 | return res |
| 66 | } |
| 67 | |
| 68 | func (t *TimePriorityQueue[T]) Remove(v T) { |
| 69 | t.tqueue.mu.Lock() |