Method Put

controller/queue.go:163–199

* If timeout less than 0, If Queue is full, return (nil, ErrFullQueue). * If timeout equals to 0, block until put a value into Queue. * If timeout greater than 0, wait timeout seconds until put a value into Queue, if timeout passed, return (nil, ErrFullQueue).

(val interface{}, timeout float64)

// * If timeout greater than 0, wait timeout seconds until put a value into Queue,
// if timeout passed, return (nil, ErrFullQueue).
func (q *Queue) Put(val interface{}, timeout float64) error {
	q.mutex.Lock()
	q.clearPending()
	isfull := q.isfull()
	if timeout < 0.0 && isfull {
		q.mutex.Unlock()
		return ErrFullQueue
	}

	if !isfull {
		if !q.notifyGetter(nil, val) {
			q.put(val)
		}
		q.mutex.Unlock()
		return nil
	}

	e := q.newPutter()
	q.mutex.Unlock()
	w := e.Value.(waiter)
	if timeout == 0.0 {
		<-w
	} else {
		select {
		case <-w:
		case <-time.After(time.Duration(timeout) * time.Second):
			return ErrFullQueue
		}
	}

	q.mutex.Lock()
	if !q.notifyGetter(e, val) {
		q.put(e)
	}
	q.mutex.Unlock()
	return nil
}

func (q *Queue) size() int {
	return q.items.Len()