marion 5 роки тому
батько
коміт
cb68564471
2 змінених файлів з 3 додано та 1 видалено
  1. 2 0
      utils/goroutine_recover.go
  2. 1 1
      utils/queue/chan_pool.go

+ 2 - 0
utils/goroutine_recover.go

@@ -13,6 +13,8 @@ func DefaultGoroutineRecover(l *logger.Logger, action string) {
 			} else {
 				log.Print(action, " goroutine 异常 ", e.Error())
 			}
+			stack := string(GetStack(0))
+			println(stack)
 		}
 	}
 }

+ 1 - 1
utils/queue/chan_pool.go

@@ -28,7 +28,7 @@ func NewChanWorker(workerId int, workerPool chan chan interface{}) *ChanWorker {
 
 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池工作对象消息处理`)
+		defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
 		for {
 			// 新工作管道或每次取用工作管道后,加入工作管道池
 			w.WorkerPool <- w.JobChannel