Method calculateTriggerTime

executor.go:152–158

(delay time.Duration)

}

func (executor *SimpleTaskExecutor) calculateTriggerTime(delay time.Duration) time.Time {
	if delay < 0 {
		delay = 0
	}

	return time.Now().Add(delay)
}

func (executor *SimpleTaskExecutor) addNewTask(task *ScheduledRunnableTask) {
	executor.newTaskChannel <- task