xtask

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

type ITask interface {
	Size() int32
	CurSize() int32
	Wait()
	Stat() Stat
	Do(args ...interface{})
	Stop()
	IsClosed() bool
}

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

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

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

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