xtask

Documentation

Index

• func Stop(tasks ...ITask)
• func Wait(tasks ...ITask)
• func WaitAndStop(tasks ...ITask)
• type Group
  • func NewGroupTask() *Group
  • func WithContext(ctx context.Context) (*Group, context.Context)
  • func (g *Group) Go(fn func())
  • func (g *Group) Wait() error
• type ITask
  • func NewAsyncTask(max int32, maxDur time.Duration, fn interface{}) ITask

Functions

func Stop

func Stop(tasks ...ITask)

func Wait

func Wait(tasks ...ITask)

func WaitAndStop

func WaitAndStop(tasks ...ITask)

Types

type Group

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

func NewGroupTask

func NewGroupTask() *Group

func WithContext

func WithContext(ctx context.Context) (*Group, context.Context)

func (*Group) Go

func (g *Group) Go(fn func())

func (*Group) Wait

func (g *Group) Wait() error

type ITask

type ITask interface {
	// all tasks
	Size() int32
	// task that running
	CurSize() int32
	// task average execution time
	CurDur() time.Duration
	// wait for task to finish
	Wait()
	Do(args ...interface{})
	Stop()
	IsClosed() bool
}

ITask interface

func NewAsyncTask

func NewAsyncTask(max int32, maxDur time.Duration, fn interface{}) ITask

NewAsyncTask max: 最大并发数 maxDur: 任务最大执行时间