We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3b7e8a5 commit ebafb71Copy full SHA for ebafb71
scheduler_test.go
@@ -585,26 +585,27 @@ func TestScheduler_Start(t *testing.T) {
585
s := newTestScheduler(t)
586
587
var counter int
588
+ var mu sync.Mutex
589
590
_, err := s.NewJob(
591
DurationJob(
592
100*time.Millisecond,
593
),
594
NewTask(
595
func() {
596
+ mu.Lock()
597
counter++
598
+ mu.Unlock()
599
},
600
601
)
602
require.NoError(t, err)
603
604
s.Start()
- time.Sleep(100 * time.Millisecond)
605
606
607
- time.Sleep(800 * time.Millisecond)
608
+ time.Sleep(1000 * time.Millisecond)
609
610
require.NoError(t, s.Shutdown())
611
0 commit comments