| 72 | } |
| 73 | |
| 74 | func (scheduler *SimpleTaskScheduler) ScheduleWithFixedDelay(task Task, delay time.Duration, options ...Option) (ScheduledTask, error) { |
| 75 | schedulerTask, err := CreateSchedulerTask(task, options...) |
| 76 | |
| 77 | if err != nil { |
| 78 | return nil, err |
| 79 | } |
| 80 | |
| 81 | return scheduler.taskExecutor.ScheduleWithFixedDelay(schedulerTask.task, schedulerTask.GetInitialDelay(), delay) |
| 82 | } |
| 83 | |
| 84 | func (scheduler *SimpleTaskScheduler) ScheduleAtFixedRate(task Task, period time.Duration, options ...Option) (ScheduledTask, error) { |
| 85 | schedulerTask, err := CreateSchedulerTask(task, options...) |