aa

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)