Merge pull request #14287 from VladSaioc/bugfix-queue-test

Fixed goroutine leak
This commit is contained in:
Benjamin Wang 2022-08-01 06:52:40 +08:00 committed by GitHub
commit 9e9e500d57
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -37,6 +37,9 @@ func TestQueueOneReaderOneWriter(t *testing.T) {
defer clus.Terminate(t)
done := make(chan struct{})
defer func() {
<-done
}()
go func() {
defer func() {
done <- struct{}{}
@ -61,7 +64,6 @@ func TestQueueOneReaderOneWriter(t *testing.T) {
t.Fatalf("expected dequeue value %v, got %v", s, i)
}
}
<-done
}
func TestQueueManyReaderOneWriter(t *testing.T) {