task

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

type ITask interface {
	Size() int
	CurSize() int
	Wait()
	Stat() Stat
	Do(name TFn, args ...interface{})
	Stop()
	// contains filtered or unexported methods
}

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"`
}

type TFn func(...interface{}) func(...interface{}) (err error)