每个worker调用该方法,从处理器中删除自己
(worker IWorker)
| 102 | |
| 103 | // 每个worker调用该方法,从处理器中删除自己 |
| 104 | func (this *EventProcessor) delWorkerByUUID(worker IWorker) { |
| 105 | this.Lock() |
| 106 | defer this.Unlock() |
| 107 | delete(this.workerQueue, worker.GetUUID()) |
| 108 | } |
| 109 | |
| 110 | // Write event |
| 111 | // 外部调用者调用该方法 |