marion 5 anni fa
parent
commit
cb4ac84bee
1 ha cambiato i file con 3 aggiunte e 3 eliminazioni
  1. 3 3
      utils/queue/chan_pool.go

+ 3 - 3
utils/queue/chan_pool.go

@@ -32,12 +32,12 @@ func NewChanWorker(workerId, capacity int, workerPool chan chan interface{}) *Ch
 }
 }
 
 
 func (w *ChanWorker) Start(callback func(workerId int, msg interface{})) {
 func (w *ChanWorker) Start(callback func(workerId int, msg interface{})) {
+	// 新工作管道加入工作管道池
+	w.WorkerPool <- w.JobChannel
+
 	go func(w *ChanWorker, callback func(workerId int, msg interface{})) {
 	go func(w *ChanWorker, callback func(workerId int, msg interface{})) {
 		defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
 		defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
 		for {
 		for {
-			// 新工作管道加入工作管道池
-			w.WorkerPool <- w.JobChannel
-
 			select {
 			select {
 			case msg := <-w.JobChannel:
 			case msg := <-w.JobChannel:
 				callback(w.ID, msg)
 				callback(w.ID, msg)