fix: enqueue

SHOWROOM-inc · Nov 17, 2023 · 064241e · 064241e
1 parent 92e6f7a
commit 064241e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/memcache/pool.go b/memcache/pool.go
@@ -66,7 +66,14 @@ func (p *pool) enqueueNewFreeConn() error {
 		createdAt:  now,
 	}
 
-	p.freeconns <- newConn
+	var wg sync.WaitGroup
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		p.freeconns <- newConn
+	}()
+	wg.Wait()
+
 	p.lk.Lock()
 	defer p.lk.Unlock()
 	p.freeconnsNum++

diff --git a/memcache/pool_test.go b/memcache/pool_test.go
@@ -1,6 +1,8 @@
 package memcache
 
-import "testing"
+import (
+	"testing"
+)
 
 func TestPool_isNewConnOk(t *testing.T) {
 	t.Run("MaxOpenConn is zero", func(t *testing.T) {