(task Task, period time.Duration, options ...Option)
| 82 | } |
| 83 | |
| 84 | func (scheduler *SimpleTaskScheduler) ScheduleAtFixedRate(task Task, period time.Duration, options ...Option) (ScheduledTask, error) { |
| 85 | schedulerTask, err := CreateSchedulerTask(task, options...) |
| 86 | |
| 87 | if err != nil { |
| 88 | return nil, err |
| 89 | } |
| 90 | |
| 91 | return scheduler.taskExecutor.ScheduleAtFixedRate(schedulerTask.task, schedulerTask.GetInitialDelay(), period) |
| 92 | } |
| 93 | |
| 94 | func (scheduler *SimpleTaskScheduler) IsShutdown() bool { |
| 95 | return scheduler.taskExecutor.IsShutdown() |