aa

utils/routinepool/routinepool.go

@@ -81,6 +81,7 @@ func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r inte
 		chanParam.resultChan = make(chan interface{})
 	}
 	p.taskChans[chanIndex] <- chanParam
+	globals.SugarLogger.Debugf("callFun %v , %v", chanIndex, primaryID)
 	if !isAsync {
 		r = <-chanParam.resultChan
 		close(chanParam.resultChan)
@@ -89,7 +90,6 @@ func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r inte
 }
 
 func (p *Pool) CallFun(func4Call func(), primaryID string) {
-	globals.SugarLogger.Debugf("CallFun %v", p.curRoutineCount)
 	if p.curRoutineCount > 0 {
 		r := p.callFun(func4Call, primaryID, false)
 		if r != nil {