From ef4ffd0b18a8c2a9120b694173fbaabc6acfc465 Mon Sep 17 00:00:00 2001
From: IllTamer <78360471+IllTamer@users.noreply.github.com>
Date: Wed, 13 Mar 2024 10:22:07 +0800
Subject: [PATCH] fix: remove unnecessary go routines

---
 internal/handle/enhance_event.go   | 5 +----
 internal/handle/serve_websocket.go | 4 +---
 2 files changed, 2 insertions(+), 7 deletions(-)

diff --git a/internal/handle/enhance_event.go b/internal/handle/enhance_event.go
index 43aadf1..5896c2f 100644
--- 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
index b0a0d9e..20498ed 100644
--- 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)
 		}
 	}
 }