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++