workpool

Documentation

Index

• Variables
• type AroundWork
• type AroundWorkFunc
  • func (f AroundWorkFunc) Around(work func())
• type WorkPool
  • func New(workers, pending int, aroundWork AroundWork) *WorkPool
  • func NewWorkPool(workers int) *WorkPool
  • func (w *WorkPool) Stop()
  • func (w *WorkPool) Submit(work func())

Variables

var DefaultAround = AroundWorkFunc(func(work func()) {
	work()
})

Types

type AroundWork

type AroundWork interface {
	Around(func())
}

type AroundWorkFunc

type AroundWorkFunc func(work func())

func (AroundWorkFunc) Around

func (f AroundWorkFunc) Around(work func())

type WorkPool

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

func New

func New(workers, pending int, aroundWork AroundWork) *WorkPool

func NewWorkPool

func NewWorkPool(workers int) *WorkPool

func (*WorkPool) Stop

func (w *WorkPool) Stop()

func (*WorkPool) Submit

func (w *WorkPool) Submit(work func())