From 06a1903d3fd417de75c11d64b1597840238280cd Mon Sep 17 00:00:00 2001 From: nolouch Date: Thu, 11 Apr 2024 15:41:31 +0800 Subject: [PATCH] fix Signed-off-by: nolouch --- pkg/ratelimit/runner_test.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/ratelimit/runner_test.go b/pkg/ratelimit/runner_test.go index 8a9eff77379..85f7d5b23c4 100644 --- a/pkg/ratelimit/runner_test.go +++ b/pkg/ratelimit/runner_test.go @@ -27,6 +27,7 @@ func TestAsyncRunner(t *testing.T) { t.Run("RunTask", func(t *testing.T) { limiter := NewConcurrencyLimiter(1) runner := NewAsyncRunner("test", time.Second) + runner.Start() defer runner.Stop() var wg sync.WaitGroup @@ -48,6 +49,7 @@ func TestAsyncRunner(t *testing.T) { t.Run("MaxPendingDuration", func(t *testing.T) { limiter := NewConcurrencyLimiter(1) runner := NewAsyncRunner("test", 2*time.Millisecond) + runner.Start() defer runner.Stop() var wg sync.WaitGroup for i := 0; i < 10; i++ {