Method ScheduleAtFixedRate

executor.go:106–129

(task Task, initialDelay time.Duration, period time.Duration)

}

func (executor *SimpleTaskExecutor) ScheduleAtFixedRate(task Task, initialDelay time.Duration, period time.Duration) (ScheduledTask, error) {
	if task == nil {
		return nil, errors.New("task cannot be nil")
	}

	executor.executorMu.Lock()

	if executor.isShutdown {
		executor.executorMu.Unlock()
		return nil, errors.New("no new task won't be accepted because executor is already shut down")
	}

	executor.nextSequence++
	scheduledTask, err := CreateScheduledRunnableTask(executor.nextSequence, task, executor.calculateTriggerTime(initialDelay), period, true)
	executor.executorMu.Unlock()

	if err != nil {
		return nil, err
	}

	executor.addNewTask(scheduledTask)

	return scheduledTask, nil
}

func (executor *SimpleTaskExecutor) IsShutdown() bool {
	executor.executorMu.Lock()