code: func (q *queue) Close() {
  	q.lock.Lock()
  	q.closed = true
  	q.lock.Unlock()
  	q.active.Broadcast()
  }
docs: // Close marks the end of the sync, unblocking Results.
  // It may be called even if the queue is already closed.