code: func (self *Queue) Close() (err error) {
  	self.lock.Lock()
  
  	self.closed = true
  	self.cond.Broadcast()
  
  	self.lock.Unlock()
  	return
  }
docs: // After Close() called, all QueueCursor's ReadPacket will return io.EOF.