Fix tests

alitto · Jun 17, 2024 · 57e5a0a · 57e5a0a
1 parent bdb616c
commit 57e5a0a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pond_test.go b/pond_test.go
@@ -39,6 +39,9 @@ func TestPurgeAfterPoolStopped(t *testing.T) {
 	pool.SubmitAndWait(func() {
 		atomic.AddInt32(&doneCount, 1)
 	})
+
+	time.Sleep(10 * time.Millisecond)
+
 	assertEqual(t, int32(1), atomic.LoadInt32(&doneCount))
 	assertEqual(t, 1, pool.RunningWorkers())
 
@@ -59,6 +62,8 @@ func TestPurgeDuringSubmit(t *testing.T) {
 		atomic.AddInt32(&doneCount, 1)
 	})
 
+	time.Sleep(10 * time.Millisecond)
+
 	assertEqual(t, 1, pool.IdleWorkers())
 
 	// Stop an idle worker right before submitting another task