Adjusting Memory Pool Parameters

lxzan · Sep 4, 2023 · c4db206 · c4db206
1 parent dcb010b
commit c4db206
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/internal/pool.go b/internal/pool.go
@@ -6,8 +6,7 @@ import (
 )
 
 const (
-	poolSize      = 10
-	maxBufferSize = 256 * 1024
+	poolSize = 10
 
 	Lv1 = 128
 	Lv2 = 1024
@@ -41,7 +40,7 @@ func (p *BufferPool) Put(b *bytes.Buffer, index int) {
 	if index == 0 || b == nil {
 		return
 	}
-	if b.Cap() <= maxBufferSize {
+	if b.Cap() <= 5*p.limits[index] {
 		p.pools[index].Put(b)
 	}
 }

diff --git a/writer.go b/writer.go
@@ -40,8 +40,8 @@ func (c *Conn) WriteString(s string) error {
 	return c.WriteMessage(OpcodeText, internal.StringToBytes(s))
 }
 
-// WriteAsync 异步写入消息
-// Asynchronous Write Messages
+// WriteAsync 异步非阻塞地写入消息
+// Write messages asynchronously and non-blocking
 func (c *Conn) WriteAsync(opcode Opcode, payload []byte) error {
 	frame, index, err := c.genFrame(opcode, payload)
 	if err != nil {