options *FIFOSchedulerOptions,
logger log.Logger,
return &FIFOScheduler[T]{
status: common.DaemonStatusInitialized,
options: options,
logger: logger,
tasksChan: make(chan T, options.QueueSize),
}
}
func (f *FIFOScheduler[T]) Start() {