taskengine

Documentation

Index

• type Task
• type TaskEngine
  • func New(ctx context.Context, name string, concurrencyLevel int, logger *zap.Logger) *TaskEngine
  • func (engine *TaskEngine) Schedule(task Task) bool
  • func (engine *TaskEngine) Shutdown()
• type TaskFunc
  • func (f TaskFunc) Run()

Types

type Task

type Task interface {
	Run()
}

Task define the task interface

type TaskEngine

type TaskEngine struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

TaskEngine define the task engine

func New

func New(ctx context.Context, name string, concurrencyLevel int, logger *zap.Logger) *TaskEngine

New create a new task engine

func (*TaskEngine) Schedule

func (engine *TaskEngine) Schedule(task Task) bool

Schedule schedule a task running on engine

func (*TaskEngine) Shutdown

func (engine *TaskEngine) Shutdown()

Shutdown stop the task engine

type TaskFunc

type TaskFunc func()

TaskFunc define the task func type

func (TaskFunc) Run

func (f TaskFunc) Run()

Run implements the Task interface