task

Documentation

Index

• Variables
• func Stop(tasks ...ITask)
• func Wait(tasks ...ITask)
• func WaitAndStop(tasks ...ITask)
• type AsyncTask
  • func NewAsyncTask(max int, maxDur time.Duration, fn interface{}) *AsyncTask
  • func (t *AsyncTask) CurSize() int
  • func (t *AsyncTask) Do(args ...interface{})
  • func (t *AsyncTask) OnError(err error)
  • func (t *AsyncTask) Size() int
  • func (t *AsyncTask) Stat() Stat
  • func (t *AsyncTask) Stop()
  • func (t *AsyncTask) Wait()
• type ITask
• type Stat

Variables

var Cfg = struct {
	Debug bool
}{
	Debug: false,
}

Cfg config

Functions

func Stop

func Stop(tasks ...ITask)

func Wait

func Wait(tasks ...ITask)

func WaitAndStop

func WaitAndStop(tasks ...ITask)

Types

type AsyncTask

type AsyncTask struct {
	ITask
	// contains filtered or unexported fields
}

AsyncTask struct

func NewAsyncTask

func NewAsyncTask(max int, maxDur time.Duration, fn interface{}) *AsyncTask

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

func (*AsyncTask) CurSize

func (t *AsyncTask) CurSize() int

CurSize get current active task size

func (*AsyncTask) Do

func (t *AsyncTask) Do(args ...interface{})

Do handle task

func (*AsyncTask) OnError

func (t *AsyncTask) OnError(err error)

OnError

func (*AsyncTask) Size

func (t *AsyncTask) Size() int

Size get current task size

func (*AsyncTask) Stat

func (t *AsyncTask) Stat() Stat

Stat get current task state

func (*AsyncTask) Stop

func (t *AsyncTask) Stop()

Stop stop task

func (*AsyncTask) Wait

func (t *AsyncTask) Wait()

Wait wait for task done

type ITask

type ITask interface {
	Size() int
	CurSize() int
	Wait()
	Stat() Stat
	Do(args ...interface{})
	Stop()
	OnError(err error)
}

ITask interface

type Stat

type Stat struct {
	// QL queue length
	QL int `json:"q_l,omitempty"`

	// CurDur current duration
	CurDur float64 `json:"cur_dur,omitempty"`

	// MaxQ max queue
	MaxQ int `json:"max_q,omitempty"`

	// MaxDur max duration
	MaxDur float64 `json:"max_dur,omitempty"`
}

Stat stat struct