fix: enqueue

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

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/memcache/pool.go b/memcache/pool.go
@@ -66,11 +66,13 @@ func (p *pool) enqueueNewFreeConn() error {
 		createdAt:  now,
 	}
 
-	p.freeconns <- newConn
-	p.lk.Lock()
-	defer p.lk.Unlock()
-	p.freeconnsNum++
-	p.openconnsNum++
+	go func() {
+		p.freeconns <- newConn
+		p.lk.Lock()
+		defer p.lk.Unlock()
+		p.freeconnsNum++
+		p.openconnsNum++
+	}()
 
 	return nil
 }

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) {