pool

Documentation

Index

• Variables
• type Pool
  • func NewPool(size int, workers int) *Pool
  • func (p *Pool) Shutdown()
  • func (p *Pool) Submit(timeout time.Duration, task Task) error
  • func (p *Pool) SubmitFn(timeout time.Duration, fn func()) error
• type Task

Variables

var (
	ErrPoolTernimated = errors.New("pool is ternimated")
	ErrTimeout        = errors.New("timeout")
)

Types

type Pool

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

func NewPool

func NewPool(size int, workers int) *Pool

func (*Pool) Shutdown

func (p *Pool) Shutdown()

func (*Pool) Submit

func (p *Pool) Submit(timeout time.Duration, task Task) error

func (*Pool) SubmitFn

func (p *Pool) SubmitFn(timeout time.Duration, fn func()) error

type Task

type Task interface {
	Execute()
}