chore: Goroutine leak detector to help avoid Goroutine leaks. (#7)

Author: appleboy

go.mod

@@ -6,4 +6,5 @@ require (
 	github.com/go-redis/redis/v8 v8.11.3
 	github.com/golang-queue/queue v0.0.11
 	github.com/stretchr/testify v1.7.0
+	go.uber.org/goleak v1.1.12
 )

go.sum

@@ -57,6 +57,7 @@ go.uber.org/goleak v1.1.12/go.mod h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/lint v0.0.0-20190930215403-16217165b5de h1:5hukYrvBGR8/eNkX5mdUezrA6JiaEZDtJb9Ei+1LlBs=
 golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
 golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
 golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
@@ -96,6 +97,7 @@ golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGm
 golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
 golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
+golang.org/x/tools v0.1.5 h1:ouewzE6p+/VEB31YYnTbEJdi8pFqKp4P4n85vwo3DHA=
 golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

redis_test.go

@@ -13,10 +13,15 @@ import (
 	"github.com/golang-queue/queue"
 
 	"github.com/stretchr/testify/assert"
+	"go.uber.org/goleak"
 )
 
 var host = "127.0.0.1"
 
+func TestMain(m *testing.M) {
+	goleak.VerifyTestMain(m)
+}
+
 type mockMessage struct {
 	Message string
 }
@@ -327,6 +332,7 @@ func TestHandleTimeout(t *testing.T) {
 	err := w.handle(job)
 	assert.Error(t, err)
 	assert.Equal(t, context.DeadlineExceeded, err)
+	assert.NoError(t, w.Shutdown())
 
 	job = queue.Job{
 		Timeout: 150 * time.Millisecond,
@@ -366,6 +372,7 @@ func TestJobComplete(t *testing.T) {
 	err := w.handle(job)
 	assert.Error(t, err)
 	assert.Equal(t, errors.New("job completed"), err)
+	assert.NoError(t, w.Shutdown())
 
 	job = queue.Job{
 		Timeout: 250 * time.Millisecond,