gohelper

Documentation

Index

• func Close(cancel func())
• func Go(f func(), errCall func(interface{}))
• func RunTasks(fs ...func())
• type GoManager
  • func NewGoManager(ctx context.Context, size int) (*GoManager, error)
  • func (g *GoManager) NewWorker(ctx context.Context, size int) (*TaskPool, error)
  • func (g *GoManager) RegisterCancel(cancel func())
  • func (g *GoManager) SetStop()
  • func (g *GoManager) Stop()
  • func (g *GoManager) Submit(f func()) error
  • func (g *GoManager) SubmitCall(f func() (error, interface{}), call func(TaskResult)) error
  • func (g *GoManager) SubmitDelay(f func(), delay time.Duration) error
  • func (g *GoManager) SubmitDelayCall(f func() (error, interface{}), call func(TaskResult), delay time.Duration) error
  • func (g *GoManager) SubmitDelayTask(task ITask, delay time.Duration) error
  • func (g *GoManager) SubmitTask(task ITask) error
  • func (g *GoManager) SubmitTimer(f func() bool, delay time.Duration) error
  • func (g *GoManager) SubmitTimerTask(task ITask, timer time.Duration) error
  • func (g *GoManager) Wait()
• type IPool
• type ITask
• type ITaskFunc
• type Task
  • func NewTask(f func() (error, interface{}), call func(TaskResult)) Task
  • func (t Task) Call(result TaskResult)
  • func (t Task) Exec() (error, interface{})
• type TaskManager
  • func NewTaskManager(maxSize int) *TaskManager
  • func (t *TaskManager) RunTasks(fs ...func())
• type TaskPool
  • func (p *TaskPool) Submit(f func()) error
  • func (p *TaskPool) SubmitCall(f func() (error, interface{}), call func(TaskResult)) error
  • func (p *TaskPool) SubmitDelay(f func(), delay time.Duration) error
  • func (p *TaskPool) SubmitDelayCall(f func() (error, interface{}), call func(TaskResult), delay time.Duration) error
  • func (p *TaskPool) SubmitDelayTask(task ITask, delay time.Duration) error
  • func (p *TaskPool) SubmitTask(task ITask) error
  • func (p *TaskPool) SubmitTimer(f func() bool, timer time.Duration) error
  • func (p *TaskPool) SubmitTimerTask(task ITask, timer time.Duration) error
  • func (p *TaskPool) Wait()
• type TaskResult

Functions

func Close

func Close(cancel func())

func Go

func Go(f func(), errCall func(interface{}))

func RunTasks

func RunTasks(fs ...func())

Types

type GoManager

type GoManager struct {
	// contains filtered or unexported fields
}

func NewGoManager

func NewGoManager(ctx context.Context, size int) (*GoManager, error)

func (*GoManager) NewWorker

func (g *GoManager) NewWorker(ctx context.Context, size int) (*TaskPool, error)

func (*GoManager) RegisterCancel

func (g *GoManager) RegisterCancel(cancel func())

func (*GoManager) SetStop

func (g *GoManager) SetStop()

func (*GoManager) Stop

func (g *GoManager) Stop()

func (*GoManager) Submit

func (g *GoManager) Submit(f func()) error

func (*GoManager) SubmitCall

func (g *GoManager) SubmitCall(f func() (error, interface{}), call func(TaskResult)) error

func (*GoManager) SubmitDelay

func (g *GoManager) SubmitDelay(f func(), delay time.Duration) error

func (*GoManager) SubmitDelayCall

func (g *GoManager) SubmitDelayCall(f func() (error, interface{}), call func(TaskResult), delay time.Duration) error

func (*GoManager) SubmitDelayTask

func (g *GoManager) SubmitDelayTask(task ITask, delay time.Duration) error

func (*GoManager) SubmitTask

func (g *GoManager) SubmitTask(task ITask) error

func (*GoManager) SubmitTimer

func (g *GoManager) SubmitTimer(f func() bool, delay time.Duration) error

func (*GoManager) SubmitTimerTask

func (g *GoManager) SubmitTimerTask(task ITask, timer time.Duration) error

func (*GoManager) Wait

func (g *GoManager) Wait()

type IPool

type IPool interface {
	Submit(task ITask)
	SubmitDelay(task ITask, delay time.Duration)
	SubmitTimer(task ITask, timer time.Duration)
	Wait()
}

type ITask

type ITask interface {
	ITaskFunc
}

type ITaskFunc

type ITaskFunc interface {
	Exec() (error, interface{})
	Call(TaskResult)
}

type Task

type Task struct {
	// contains filtered or unexported fields
}

func NewTask

func NewTask(f func() (error, interface{}), call func(TaskResult)) Task

func (Task) Call

func (t Task) Call(result TaskResult)

func (Task) Exec

func (t Task) Exec() (error, interface{})

type TaskManager

type TaskManager struct {
	// contains filtered or unexported fields
}

func NewTaskManager

func NewTaskManager(maxSize int) *TaskManager

func (*TaskManager) RunTasks

func (t *TaskManager) RunTasks(fs ...func())

type TaskPool

type TaskPool struct {
	// contains filtered or unexported fields
}

func (*TaskPool) Submit

func (p *TaskPool) Submit(f func()) error

func (*TaskPool) SubmitCall

func (p *TaskPool) SubmitCall(f func() (error, interface{}), call func(TaskResult)) error

func (*TaskPool) SubmitDelay

func (p *TaskPool) SubmitDelay(f func(), delay time.Duration) error

func (*TaskPool) SubmitDelayCall

func (p *TaskPool) SubmitDelayCall(f func() (error, interface{}), call func(TaskResult), delay time.Duration) error

func (*TaskPool) SubmitDelayTask

func (p *TaskPool) SubmitDelayTask(task ITask, delay time.Duration) error

func (*TaskPool) SubmitTask

func (p *TaskPool) SubmitTask(task ITask) error

func (*TaskPool) SubmitTimer

func (p *TaskPool) SubmitTimer(f func() bool, timer time.Duration) error

定时任务返回true则继续执行 否则停止

func (*TaskPool) SubmitTimerTask

func (p *TaskPool) SubmitTimerTask(task ITask, timer time.Duration) error

func (*TaskPool) Wait

func (p *TaskPool) Wait()

type TaskResult

type TaskResult struct {
	Err  error
	Data interface{}
}

TaskResult 任务结果