diff --git a/utils/routinepool/routinepool.go b/utils/routinepool/routinepool.go index cea7ef26..8d53c585 100644 --- a/utils/routinepool/routinepool.go +++ b/utils/routinepool/routinepool.go @@ -74,14 +74,16 @@ func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r inte result := md5.Sum([]byte(primaryID)) resultInt64 := int64(binary.LittleEndian.Uint32(result[8:])) chanIndex := int(resultInt64 % int64(p.curRoutineCount)) + globals.SugarLogger.Debugf("callFun1 %v , %v", chanIndex, primaryID) chanParam := &TaskParam{ handler: func4Call, } if !isAsync { chanParam.resultChan = make(chan interface{}) } + globals.SugarLogger.Debugf("callFun2 %v , %v", chanIndex, primaryID) p.taskChans[chanIndex] <- chanParam - globals.SugarLogger.Debugf("callFun %v , %v", chanIndex, primaryID) + globals.SugarLogger.Debugf("callFun3 %v , %v", chanIndex, primaryID) if !isAsync { r = <-chanParam.resultChan close(chanParam.resultChan)