parallel

Documentation

Index

• type Job
• type SPool
  • func NewSPool(workerNum int, totalNum int, timeout int, debug bool) *SPool
  • func (p *SPool) Commit(w WorkerInterface)
  • func (p *SPool) CountFail()
  • func (p *SPool) CountOk()
  • func (p *SPool) CountOut()
  • func (p *SPool) Release()
  • func (p *SPool) Runtimelog()
• type SPoolFunc
  • func NewSPoolFunc(workerNum int, totalNum int, debug bool, job Job) *SPoolFunc
  • func (p *SPoolFunc) Commit(id string)
  • func (p *SPoolFunc) Release()
• type WorkerInterface

Types

type Job

type Job func(string) error

type SPool

type SPool struct {
	TotalNum    int
	CounterOk   int
	CounterFail int
	CounterOut  int

	TimeStart int64
	TimeOut   int
	Debug     bool
	// contains filtered or unexported fields
}

/共享协程池

func NewSPool

func NewSPool(workerNum int, totalNum int, timeout int, debug bool) *SPool

协程池 timeout=0 关闭超时统计 debug=true 打开模式

func (*SPool) Commit

func (p *SPool) Commit(w WorkerInterface)

提交任务

func (*SPool) CountFail

func (p *SPool) CountFail()

计数器-失败

func (*SPool) CountOk

func (p *SPool) CountOk()

计数器-执行成功

func (*SPool) CountOut

func (p *SPool) CountOut()

计数器-超时

func (*SPool) Release

func (p *SPool) Release()

等待组 关闭channel

func (*SPool) Runtimelog

func (p *SPool) Runtimelog()

log

type SPoolFunc

type SPoolFunc struct {
	TotalNum    int
	CounterOk   int
	CounterFail int
	CounterOut  int

	TimeStart int64
	TimeOut   int
	Debug     bool
	// contains filtered or unexported fields
}

/共享协程池

func NewSPoolFunc

func NewSPoolFunc(workerNum int, totalNum int, debug bool, job Job) *SPoolFunc

协程池 timeout=0 关闭超时统计 debug=true 打开模式

func (*SPoolFunc) Commit

func (p *SPoolFunc) Commit(id string)

提交任务

func (*SPoolFunc) Release

func (p *SPoolFunc) Release()

等待组 关闭channel

type WorkerInterface

type WorkerInterface interface {
	Task() error
	GetTaskID() interface{}
}