From 9cd9b6a3c6cfcf185b45e4ae32369eada9d7c597 Mon Sep 17 00:00:00 2001 From: wangzhuowei Date: Fri, 26 Jul 2024 18:47:56 +0800 Subject: [PATCH] fix: TestChannelNoConsumer race --- lang/channel/channel_test.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/lang/channel/channel_test.go b/lang/channel/channel_test.go index fd99463..438a0d5 100644 --- a/lang/channel/channel_test.go +++ b/lang/channel/channel_test.go @@ -305,11 +305,11 @@ func TestChannelGoroutinesThrottle(t *testing.T) { func TestChannelNoConsumer(t *testing.T) { // zero size channel - ch := New() + ch1 := New() var sum int32 go func() { for i := 1; i <= 20; i++ { - ch.Input(i) + ch1.Input(i) //tlogf(t, "producer=%d finished", i) atomic.AddInt32(&sum, 1) } @@ -318,11 +318,11 @@ func TestChannelNoConsumer(t *testing.T) { assert.Equal(t, int32(2), atomic.LoadInt32(&sum)) // 1 size channel - ch = New(WithSize(1)) + ch2 := New(WithSize(1)) atomic.StoreInt32(&sum, 0) go func() { for i := 1; i <= 20; i++ { - ch.Input(i) + ch2.Input(i) //tlogf(t, "producer=%d finished", i) atomic.AddInt32(&sum, 1) } @@ -331,11 +331,11 @@ func TestChannelNoConsumer(t *testing.T) { assert.Equal(t, int32(2), atomic.LoadInt32(&sum)) // 10 size channel - ch = New(WithSize(10)) + ch3 := New(WithSize(10)) atomic.StoreInt32(&sum, 0) go func() { for i := 1; i <= 20; i++ { - ch.Input(i) + ch3.Input(i) //tlogf(t, "producer=%d finished", i) atomic.AddInt32(&sum, 1) }