aa

utils/routinepool/routinepool.go

@@ -6,13 +6,14 @@ import (
 	"fmt"
 	"runtime/debug"
 
+	"git.rosy.net.cn/baseapi"
 	"git.rosy.net.cn/jx-callback/globals"
 
 	"git.rosy.net.cn/baseapi/utils"
 )
 
 const (
-	chanPoolSize = 8
+	chanPoolSize = 20
 )
 
 type TaskParam struct {
@@ -61,7 +62,7 @@ func callHandler(handler func()) (retVal interface{}) {
 func taskFun(taskChan chan *TaskParam, index int) {
 	for {
 		taskParam := <-taskChan
-		// baseapi.SugarLogger.Debugf("routine:%d, handle task:%v", index, taskParam.handler)
+		baseapi.SugarLogger.Debugf("routine:%d, handle task:%v", index, taskParam.handler)
 		result := callHandler(taskParam.handler)
 		if taskParam.resultChan != nil {
 			taskParam.resultChan <- result