优化pool

2025-11-26 21:25:35 +08:00 · 2025-02-21 15:07:20 +08:00
parent bbc2013cd6
commit c6f68ee031
1 changed files with 3 additions and 0 deletions
--- a/pool.go
+++ b/pool.go
@@ -6,6 +6,9 @@ import (
 )

 func NewPool(dial func() (*Client, error), number int) (*Pool, error) {
+	if number <= 0 {
+		number = 1
+	}
 	ch := make(chan *Client, number)
 	p := &Pool{
 		ch: ch,