Method notifyGetter

controller/queue.go:71–83

(putter *list.Element, val interface{})

}

func (q *Queue) notifyGetter(putter *list.Element, val interface{}) bool {
	if putter != nil {
		q.putters.Remove(putter)
	}
	if q.getters.Len() == 0 {
		return false
	}
	e := q.getters.Front()
	q.getters.Remove(e)
	w := e.Value.(waiter)
	w <- val
	return true
}

func (q *Queue) clearPending() {
	for !q.isfull() && q.putters.Len() != 0 {