hsun 10 months ago
parent
commit
e3494a483f
1 changed files with 4 additions and 3 deletions
  1. 4 3
      services/data/edb_refresh.go

+ 4 - 3
services/data/edb_refresh.go

@@ -62,10 +62,11 @@ func HandleEdbRefreshQueue() {
 
 	for {
 		select {
-		case item := <-EdbRefreshHandling:
+		case item, ok := <-EdbRefreshHandling:
+			if !ok {
+				return
+			}
 			go EdbRefreshTask(item)
-		default:
-			continue
 		}
 	}
 }