Function NewSimpleTaskExecutor

executor.go:35–54

(runner TaskRunner)

}

func NewSimpleTaskExecutor(runner TaskRunner) *SimpleTaskExecutor {
	if runner == nil {
		runner = NewDefaultTaskRunner()
	}

	executor := &SimpleTaskExecutor{
		timer:                 time.NewTimer(1 * time.Hour),
		taskQueue:             make(ScheduledTaskQueue, 0),
		newTaskChannel:        make(chan *ScheduledRunnableTask),
		rescheduleTaskChannel: make(chan *ScheduledRunnableTask),
		taskRunner:            runner,
		shutdownChannel:       make(chan chan bool),
	}

	executor.timer.Stop()

	go executor.run()

	return executor
}

func (executor *SimpleTaskExecutor) Schedule(task Task, delay time.Duration) (ScheduledTask, error) {
	if task == nil {