marion hace 5 años
padre
commit
2d8150d265
Se han modificado 1 ficheros con 1 adiciones y 1 borrados
  1. 1 1
      utils/queue/chan_pool.go

+ 1 - 1
utils/queue/chan_pool.go

@@ -35,7 +35,7 @@ func (w *ChanWorker) Start(callback func(workerId int, msg interface{})) {
 	go func(w *ChanWorker, callback func(workerId int, msg interface{})) {
 		defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
 		for {
-			// 新工作管道加入工作管道池
+			// 新工作管道或每次取用工作管道后,加入工作管道池
 			w.WorkerPool <- w.JobChannel
 
 			select {