fix: remove unnecessary go routines

IUnlimit · Mar 13, 2024 · ef4ffd0 · ef4ffd0
1 parent fe09813
commit ef4ffd0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/internal/handle/enhance_event.go b/internal/handle/enhance_event.go
@@ -3,7 +3,6 @@ package handle
 import (
 	global "github.com/IUnlimit/perpetua/internal"
 	"github.com/IUnlimit/perpetua/internal/model"
-	"github.com/bytedance/gopkg/util/gopool"
 	log "github.com/sirupsen/logrus"
 	"time"
 )
@@ -72,8 +71,6 @@ func broadcast(trigger *Handler, targets []interface{}, jumpTrigger bool, msgDat
 		if jumpTrigger && handler.GetId() == trigger.GetId() {
 			continue
 		}
-		gopool.Go(func() {
-			handler.AddMessage(uuid)
-		})
+		handler.AddMessage(uuid)
 	}
 }
diff --git a/internal/handle/serve_websocket.go b/internal/handle/serve_websocket.go
@@ -146,9 +146,7 @@ func readFromNTQQLoop(handle *Handler, conn *websocket.Conn) error {
 		// when closed, staying dispatch
 		for _, v := range receivers {
 			handler := v.(*Handler)
-			gopool.Go(func() {
-				handler.AddMessage(uuid)
-			})
+			handler.AddMessage(uuid)
 		}
 	}
 }