Method Advance

queue.go:106–113

Advance executes OnTimer callbacks for all timers scheduled to be run before the time 'tm'. Executed timers are removed from the timer queue.

(tm time.Time)

// run before the time 'tm'. Executed timers are removed from the
// timer queue.
func (q *Queue) Advance(tm time.Time) {
	for len(q.heap) > 0 && !tm.Before(q.heap[0].time) {
		data := q.heap[0]
		heap.Remove(&q.heap, data.index)
		delete(q.table, data.timer)
		data.timer.OnTimer(data.time)
	}
}

/*
 * timerHeap