From ba0082d98b23d62d2369bb9808758829a4fad06c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Thu, 8 Apr 2021 18:28:05 +0800
Subject: [PATCH] aa

---
 utils/routinepool/routinepool.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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)