worker

Documentation

Index

• type DirectWorker
  • func (DirectWorker) Submit(task func())
  • func (DirectWorker) SubmitAndWait(task func())
  • func (DirectWorker) SubmitBefore(task func(), dur time.Duration)
• type Pond
  • func CreateNewPond(targetName string) *Pond
  • func NewPond(max int, poolSize int, workers ...pond.Option) *Pond
  • func (p *Pond) Submit(task func())
  • func (p *Pond) SubmitAndWait(task func())
  • func (p *Pond) SubmitBefore(task func(), dur time.Duration)
• type Worker
  • func Get(name ...string) Worker

Types

type DirectWorker

type DirectWorker struct{}

func (DirectWorker) Submit

func (DirectWorker) Submit(task func())

func (DirectWorker) SubmitAndWait

func (DirectWorker) SubmitAndWait(task func())

func (DirectWorker) SubmitBefore

func (DirectWorker) SubmitBefore(task func(), dur time.Duration)

type Pond

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

func CreateNewPond

func CreateNewPond(targetName string) *Pond

func NewPond

func NewPond(max int, poolSize int, workers ...pond.Option) *Pond

func (*Pond) Submit

func (p *Pond) Submit(task func())

func (*Pond) SubmitAndWait

func (p *Pond) SubmitAndWait(task func())

func (*Pond) SubmitBefore

func (p *Pond) SubmitBefore(task func(), dur time.Duration)

type Worker

type Worker interface {
	Submit(task func())
	SubmitAndWait(task func())
	SubmitBefore(task func(), dur time.Duration)
}

func Get

func Get(name ...string) Worker