aa
This commit is contained in:
@@ -86,6 +86,7 @@ func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r inte
|
||||
globals.SugarLogger.Debugf("callFun3 %v , %v", chanIndex, primaryID)
|
||||
if !isAsync {
|
||||
r = <-chanParam.resultChan
|
||||
globals.SugarLogger.Debugf("callFun4 %v , %v", chanIndex, primaryID)
|
||||
close(chanParam.resultChan)
|
||||
}
|
||||
return r
|
||||
|
||||
Reference in New Issue
Block a user