aa
This commit is contained in:
@@ -88,7 +88,7 @@ func (p *Pool) callFun(func4Call func(), primaryID string, isAsync bool) (r inte
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (p *Pool) CallFun(func4Call func(), primaryID string) {
|
func (p *Pool) CallFun(func4Call func(), primaryID string) {
|
||||||
globals.SugarLogger.Debugf("CallFun %v", utils.Format4Output(p, true))
|
globals.SugarLogger.Debugf("CallFun %v", utils.Format4Output(p.curRoutineCount, true))
|
||||||
if p.curRoutineCount > 0 {
|
if p.curRoutineCount > 0 {
|
||||||
r := p.callFun(func4Call, primaryID, false)
|
r := p.callFun(func4Call, primaryID, false)
|
||||||
if r != nil {
|
if r != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user