code: func (q *BaseQueue) SetProcessor(processor Processor) {
  	q.pmu.Lock()
  	defer q.pmu.Unlock()
  
  	q.processor = processor
  }
docs: // SetProcessor implements the SetProcessor method on the Queue interface. It
  // functions by requesting write-level access from the guarding mutex and
  // preforms the update atomically.