perf: use gopool

ppzqh · Jan 31, 2025 · bc6b4b2 · bc6b4b2
1 parent 49b8cdf
commit bc6b4b2
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -9,7 +9,7 @@ require (
 	github.com/cloudwego/dynamicgo v0.5.1-0.20250115031329-d58b94fc7d71
 	github.com/cloudwego/fastpb v0.0.5
 	github.com/cloudwego/frugal v0.2.3
-	github.com/cloudwego/gopkg v0.1.4-0.20241217093255-8980b14172b7
+	github.com/cloudwego/gopkg v0.1.4-0.20250108101532-52ba6073f5a1
 	github.com/cloudwego/localsession v0.1.2
 	github.com/cloudwego/netpoll v0.6.5
 	github.com/cloudwego/runtimex v0.1.1

diff --git a/go.sum b/go.sum
@@ -23,6 +23,8 @@ github.com/cloudwego/frugal v0.2.3 h1:t1hhhAi8lXcx7Ncs4PR1pSZ90vlDU1cy5K2btDMFpo
 github.com/cloudwego/frugal v0.2.3/go.mod h1:nC1U47gswLRiaxv6dybrhZvsDGCfQP9RGiiWC73CnoI=
 github.com/cloudwego/gopkg v0.1.4-0.20241217093255-8980b14172b7 h1:RmKES3lXoM62rUVEEy0teTsPYNBtFpqSN1lYBw4v82g=
 github.com/cloudwego/gopkg v0.1.4-0.20241217093255-8980b14172b7/go.mod h1:FQuXsRWRsSqJLsMVd5SYzp8/Z1y5gXKnVvRrWUOsCMI=
+github.com/cloudwego/gopkg v0.1.4-0.20250108101532-52ba6073f5a1 h1:qkodCQ1+B+5GM9i/XplrZ54oSI/FEAl3OQYJFIJHeDY=
+github.com/cloudwego/gopkg v0.1.4-0.20250108101532-52ba6073f5a1/go.mod h1:FQuXsRWRsSqJLsMVd5SYzp8/Z1y5gXKnVvRrWUOsCMI=
 github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
 github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
 github.com/cloudwego/localsession v0.1.2 h1:RBmeLDO5sKr4ujd8iBp5LTMmuVKLdu88jjIneq/fEZ8=

diff --git a/pkg/remote/trans/gonet/trans_server.go b/pkg/remote/trans/gonet/trans_server.go
@@ -26,6 +26,8 @@ import (
 	"sync"
 	"time"
 
+	"github.com/cloudwego/gopkg/concurrency/gopool"
+
 	"github.com/cloudwego/netpoll"
 
 	"github.com/cloudwego/kitex/pkg/remote/trans"
@@ -82,7 +84,7 @@ func (ts *transServer) BootstrapServer(ln net.Listener) (err error) {
 			klog.Errorf("KITEX: BootstrapServer accept failed, err=%s", err.Error())
 			os.Exit(1)
 		}
-		go func() {
+		gopool.CtxGo(nil, func() {
 			var (
 				ctx = context.Background()
 				err error
@@ -114,7 +116,7 @@ func (ts *transServer) BootstrapServer(ln net.Listener) (err error) {
 					return
 				}
 			}
-		}()
+		})
 	}
 }