(t *testing.T)
| 270 | } |
| 271 | |
| 272 | func TestSimpleTaskScheduler_ScheduleWithCron(t *testing.T) { |
| 273 | scheduler := NewSimpleTaskScheduler(NewDefaultTaskExecutor()) |
| 274 | |
| 275 | var counter int32 |
| 276 | |
| 277 | task, err := scheduler.ScheduleWithCron(func(ctx context.Context) { |
| 278 | atomic.AddInt32(&counter, 1) |
| 279 | <-time.After(500 * time.Millisecond) |
| 280 | }, "0-59/2 * * * * *") |
| 281 | |
| 282 | assert.Nil(t, err) |
| 283 | |
| 284 | <-time.After(10 * time.Second) |
| 285 | task.Cancel() |
| 286 | assert.True(t, counter >= 5, |
| 287 | "number of scheduled task execution must be at least 5, actual: %d", counter) |
| 288 | } |
| 289 | |
| 290 | func TestSimpleTaskScheduler_Shutdown(t *testing.T) { |
| 291 | scheduler := NewSimpleTaskScheduler(NewDefaultTaskExecutor()) |
nothing calls this directly
no test coverage detected