Versions in this module Expand all Collapse all v1 v1.0.4 Jul 20, 2023 v1.0.2 Jul 20, 2023 Changes in this version + var TaskExecutorClosedError = errors.New("任务执行器已关闭") + type Task interface + Do func(interrupter chan struct{}) (interrupted bool) + func Func(fn func()) Task + func Interrupted(fn func(interrupter chan struct{}) (interrupted bool)) Task + func Nop() Task + type TaskExecutor struct + func NewTaskExecutor(maxTask int) *TaskExecutor + func (e *TaskExecutor) Async(task Task) error + func (e *TaskExecutor) RunFunc() lifecycle.InterruptedRunFunc + func (e *TaskExecutor) StartFunc() lifecycle.InterruptedStartFunc + func (e *TaskExecutor) Sync(task Task) error + func (e *TaskExecutor) Try(task Task) (ok bool, err error) + func (e *TaskExecutor) Wait() error