process

Documentation

Index

• Constants
• func AddJob(work *WorkProcess, workJob *WorkJob)
• func StopWork(work *WorkProcess)
• type ProcessStatus
• type WorkJob
• type WorkProcess
  • func New() *WorkProcess
  • func (this *WorkProcess) Init(maxProcessCount int, workListMaxCount int, processTimeOut int)
  • func (this *WorkProcess) Init_Default()

Constants

const (
	DefaultMaxProcessCount  = 10
	DefaultWorkListMaxCount = 2000
	DefaultTimeOut          = 1000
)

Functions

func AddJob

func AddJob(work *WorkProcess, workJob *WorkJob)

func StopWork

func StopWork(work *WorkProcess)

Types

type ProcessStatus

type ProcessStatus int

const (
	Create ProcessStatus = iota
	Start
	Stop
	Receive
	Finish
	TimeOut
)

type WorkJob

type WorkJob struct {
	Parameter   interface{}
	Result      interface{}
	WorkProcess func(interface{}) interface{}
	// contains filtered or unexported fields
}

type WorkProcess

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

func New

func New() *WorkProcess

func (*WorkProcess) Init

func (this *WorkProcess) Init(maxProcessCount int, workListMaxCount int, processTimeOut int)

func (*WorkProcess) Init_Default

func (this *WorkProcess) Init_Default()