basic

Documentation

Index

• type Pool
  • func NewPool(workers, queueSize int) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Submit(task Task) error
  • func (pool *Pool) Work()
• type Task

Types

type Pool

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

Pool of work coroutines struct

func NewPool

func NewPool(workers, queueSize int) *Pool

New goroutine pool with workers counts and capacity

func (*Pool) Close

func (p *Pool) Close()

Gracefully close the pool

func (*Pool) Submit

func (p *Pool) Submit(task Task) error

Submit tasks to the pool

func (*Pool) Work

func (pool *Pool) Work()

Worker goroutine

type Task

type Task func()

Task should be a function receive nothing and return nothing