feat: 防止阻塞批量任务

opentdp · Dec 15, 2023 · 1541fa1 · 1541fa1
1 parent 1083b41
commit 1541fa1
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/module/worker/connect.go b/module/worker/connect.go
@@ -56,13 +56,13 @@ func Receiver(pod *socket.WsConn) error {
 
 		switch rq.Method {
 		case "Exec":
-			recv.Exec(rq)
+			go recv.Exec(rq)
 		case "Stat":
-			recv.Stat(rq)
+			go recv.Stat(rq)
 		case "Filer":
-			recv.Filer(rq)
+			go recv.Filer(rq)
 		case "Ping:resp":
-			resp.Ping(rq)
+			go resp.Ping(rq)
 		case "Register:resp":
 			go resp.Register(rq)
 		default:

diff --git a/module/workhub/connect.go b/module/workhub/connect.go
@@ -65,15 +65,15 @@ func Receiver(worker *Worker) error {
 
 		switch rq.Method {
 		case "Register":
-			recv.Register(rq)
+			go recv.Register(rq)
 		case "Ping":
-			recv.Ping(rq)
+			go recv.Ping(rq)
 		case "Exec:resp":
-			resp.Exec(rq)
+			go resp.Exec(rq)
 		case "Filer:resp":
-			resp.Filer(rq)
+			go resp.Filer(rq)
 		case "Stat:resp":
-			resp.Stat(rq)
+			go resp.Stat(rq)
 		default:
 			logman.Warn("unknown task", "request", rq)
 		}