增加队列崩溃回调

peer/redix/connector.go

@@ -80,7 +80,7 @@ func (self *redisConnector) tryConnect() {
 				}
 			}
 
-			log.Infof("Create redis pool connection: %s", addr)
+			log.Infof("Create redis pool connection: %s name: %s index: %d", addr, self.Name(), self.DBIndex)
 
 			return client, nil
 		})

queue.go

@@ -25,19 +25,28 @@ type EventQueue interface {
 	EnableCapturePanic(v bool)
 }
 
+type CapturePanicNotifyFunc func(interface{}, EventQueue)
+
 type eventQueue struct {
 	*Pipe
 
 	endSignal sync.WaitGroup
 
 	capturePanic bool
+
+	onPanic CapturePanicNotifyFunc
 }
 
 // 启动崩溃捕获
 func (self *eventQueue) EnableCapturePanic(v bool) {
 	self.capturePanic = v
 }
 
+// 设置捕获崩溃通知
+func (self *eventQueue) SetCapturePanicNotify(callback CapturePanicNotifyFunc) {
+	self.onPanic = callback
+}
+
 // 派发事件处理回调到队列中
 func (self *eventQueue) Post(callback func()) {
 
@@ -55,8 +64,7 @@ func (self *eventQueue) protectedCall(callback func()) {
 		defer func() {
 
 			if err := recover(); err != nil {
-				fmt.Println("[ERRO] panic captured!")
-				debug.PrintStack()
+				self.onPanic(err, self)
 			}
 
 		}()
@@ -117,6 +125,13 @@ func NewEventQueue() EventQueue {
 
 	return &eventQueue{
 		Pipe: NewPipe(),
+
+		// 默认的崩溃捕获打印
+		onPanic: func(raw interface{}, queue EventQueue) {
+
+			fmt.Printf("%v \n%s\n", raw, string(debug.Stack()))
+			debug.PrintStack()
+		},
 	}
 }