diff --git a/utils/routinepool/routinepool.go b/utils/routinepool/routinepool.go index 43d65fe2..cea7ef26 100644 --- a/utils/routinepool/routinepool.go +++ b/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 {