fix(leak): goroutine leak

redis channel default buffer size is 100

Signed-off-by: Bo-Yi Wu <[email protected]>

Author: appleboy

README.md

@@ -20,9 +20,9 @@ start the redis cluster, see the [config](./conf/redis.conf)
 
 ```sh
 # server 01
-mkdir server01 && cd server 01 && redis-server redis.conf --port 6379
+mkdir server01 && cd server01 && redis-server redis.conf --port 6379
 # server 02
-mkdir server02 && cd server 02 && redis-server redis.conf --port 6380
+mkdir server02 && cd server02 && redis-server redis.conf --port 6380
 ```
 
 ## Example

redis_test.go

@@ -260,13 +260,12 @@ func TestGoroutineLeak(t *testing.T) {
 	assert.NoError(t, err)
 	q.Start()
 	time.Sleep(50 * time.Millisecond)
-	for i := 0; i < 500; i++ {
+	for i := 0; i < 50; i++ {
 		m.Message = fmt.Sprintf("foobar: %d", i+1)
 		assert.NoError(t, q.Queue(m))
 	}
 	time.Sleep(1 * time.Second)
-	q.Shutdown()
-	q.Wait()
+	q.Release()
 	time.Sleep(1 * time.Second)
 	fmt.Println("number of goroutines:", runtime.NumGoroutine())
 }