(worker IWorker)
| 95 | } |
| 96 | |
| 97 | func (this *EventProcessor) addWorkerByUUID(worker IWorker) { |
| 98 | this.Lock() |
| 99 | defer this.Unlock() |
| 100 | this.workerQueue[worker.GetUUID()] = worker |
| 101 | } |
| 102 | |
| 103 | // 每个worker调用该方法，从处理器中删除自己 |
| 104 | func (this *EventProcessor) delWorkerByUUID(worker IWorker) { |