|
|
@@ -51,23 +51,23 @@ func PushEdb2Refresh(item EdbQueueRefreshReq) {
|
|
|
|
|
|
// HandleEdbRefreshQueue 排队刷新指标
|
|
|
func HandleEdbRefreshQueue() {
|
|
|
- defer func() {
|
|
|
- if err := recover(); err != nil {
|
|
|
- tips := fmt.Sprintf("[HandleEdbRefreshQueue] panic: %v", err)
|
|
|
- fmt.Println(tips)
|
|
|
- utils.FileLog.Info(tips)
|
|
|
- }
|
|
|
- }()
|
|
|
- fmt.Println("HandleEdbRefreshQueue start")
|
|
|
-
|
|
|
- for {
|
|
|
- select {
|
|
|
- case item := <-EdbRefreshHandling:
|
|
|
- go EdbRefreshTask(item)
|
|
|
- default:
|
|
|
- continue
|
|
|
- }
|
|
|
- }
|
|
|
+ //defer func() {
|
|
|
+ // if err := recover(); err != nil {
|
|
|
+ // tips := fmt.Sprintf("[HandleEdbRefreshQueue] panic: %v", err)
|
|
|
+ // fmt.Println(tips)
|
|
|
+ // utils.FileLog.Info(tips)
|
|
|
+ // }
|
|
|
+ //}()
|
|
|
+ //fmt.Println("HandleEdbRefreshQueue start")
|
|
|
+ //
|
|
|
+ //for {
|
|
|
+ // select {
|
|
|
+ // case item := <-EdbRefreshHandling:
|
|
|
+ // go EdbRefreshTask(item)
|
|
|
+ // default:
|
|
|
+ // continue
|
|
|
+ // }
|
|
|
+ //}
|
|
|
}
|
|
|
|
|
|
// EdbRefreshTask 指标刷新任务
|
