aa

utils/routinepool/routinepool.go

@@ -71,7 +71,7 @@ func taskFun(taskChan chan *TaskParam, index int) {
 }
 
 func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r interface{}) {
-	result := md5.Sum([]byte(primaryID))
+	result := md5.Sum([]byte(primaryID+utils.GetUUID()))
 	resultInt64 := int64(binary.LittleEndian.Uint32(result[8:]))
 	chanIndex := int(resultInt64 % int64(p.curRoutineCount))
 	globals.SugarLogger.Debugf("callFun1 %v , %v", chanIndex, primaryID)