task

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2019 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Cfg config

Functions

func Stop added in v0.1.2 

func Stop(tasks ...ITask)

func Wait added in v0.1.2 

func Wait(tasks ...ITask)

func WaitAndStop added in v0.1.2 

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 added in v0.1.2 

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 added in v0.1.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.