Method Shutdown

executor.go:137–150

()

}

func (executor *SimpleTaskExecutor) Shutdown() chan bool {
	executor.executorMu.Lock()
	defer executor.executorMu.Unlock()

	if executor.isShutdown {
		panic("executor is already shut down")
	}

	executor.isShutdown = true

	stoppedChan := make(chan bool)
	executor.shutdownChannel <- stoppedChan
	return stoppedChan
}

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