From 55cbbf7f41f85f82a97b81c8157ae0fcc83504af Mon Sep 17 00:00:00 2001 From: wwqgtxx Date: Wed, 16 Apr 2025 13:13:01 +0800 Subject: [PATCH] fix: singledo test --- common/singledo/singledo_test.go | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/common/singledo/singledo_test.go b/common/singledo/singledo_test.go index 2f92f0ae..f27650fb 100644 --- a/common/singledo/singledo_test.go +++ b/common/singledo/singledo_test.go @@ -11,12 +11,13 @@ import ( ) func TestBasic(t *testing.T) { - single := NewSingle[int](time.Millisecond * 30) + t.Parallel() + single := NewSingle[int](time.Millisecond * 200) foo := 0 shardCount := atomic.NewInt32(0) call := func() (int, error) { foo++ - time.Sleep(time.Millisecond * 5) + time.Sleep(time.Millisecond * 20) return 0, nil } @@ -39,7 +40,8 @@ func TestBasic(t *testing.T) { } func TestTimer(t *testing.T) { - single := NewSingle[int](time.Millisecond * 30) + t.Parallel() + single := NewSingle[int](time.Millisecond * 200) foo := 0 callM := func() (int, error) { foo++ @@ -47,7 +49,7 @@ func TestTimer(t *testing.T) { } _, _, _ = single.Do(callM) - time.Sleep(10 * time.Millisecond) + time.Sleep(100 * time.Millisecond) _, _, shard := single.Do(callM) assert.Equal(t, 1, foo) @@ -55,7 +57,8 @@ func TestTimer(t *testing.T) { } func TestReset(t *testing.T) { - single := NewSingle[int](time.Millisecond * 30) + t.Parallel() + single := NewSingle[int](time.Millisecond * 200) foo := 0 callM := func() (int, error) { foo++