workers

Documentation

Index

• type Workers
  • func New(wg *sync.WaitGroup, quit chan struct{}, maxTasks int) *Workers
  • func (w *Workers) Drain()
  • func (w *Workers) Enqueue(fn func()) error
  • func (w *Workers) Start(workersN int)
  • func (w *Workers) TasksCount() int

Types

type Workers

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

func New

func New(wg *sync.WaitGroup, quit chan struct{}, maxTasks int) *Workers

func (*Workers) Drain

func (w *Workers) Drain()

func (*Workers) Enqueue

func (w *Workers) Enqueue(fn func()) error

func (*Workers) Start

func (w *Workers) Start(workersN int)

func (*Workers) TasksCount

func (w *Workers) TasksCount() int