task

Documentation

Index

• Variables
• type Task
  • func Func(fn func()) Task
  • func Interrupted(fn func(interrupter chan struct{}) (interrupted bool)) Task
  • func Nop() Task
• type TaskExecutor
  • 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

Variables

var TaskExecutorClosedError = errors.New("任务执行器已关闭")

Types

type Task

type Task interface {
	Do(interrupter chan struct{}) (interrupted bool)
}

func Func

func Func(fn func()) Task

func Interrupted

func Interrupted(fn func(interrupter chan struct{}) (interrupted bool)) Task

func Nop

func Nop() Task

type TaskExecutor

type TaskExecutor struct {
	lifecycle.Lifecycle
	// contains filtered or unexported fields
}

func NewTaskExecutor

func NewTaskExecutor(maxTask int) *TaskExecutor

func (*TaskExecutor) Async

func (e *TaskExecutor) Async(task Task) error

func (*TaskExecutor) RunFunc

func (e *TaskExecutor) RunFunc() lifecycle.InterruptedRunFunc

func (*TaskExecutor) StartFunc

func (e *TaskExecutor) StartFunc() lifecycle.InterruptedStartFunc

func (*TaskExecutor) Sync

func (e *TaskExecutor) Sync(task Task) error

func (*TaskExecutor) Try

func (e *TaskExecutor) Try(task Task) (ok bool, err error)

func (*TaskExecutor) Wait

func (e *TaskExecutor) Wait() error