Method clearPending

controller/queue.go:85–93

()

}

func (q *Queue) clearPending() {
	for !q.isfull() && q.putters.Len() != 0 {
		q.notifyPutter(nil)
	}
	for !q.isempty() && q.getters.Len() != 0 {
		v := q.get()
		q.notifyGetter(nil, v)
	}
}

func (q *Queue) get() interface{} {
	e := q.items.Front()