workers

Documentation

Index

• Variables
• type Pool
  • func NewPool(size ...int) *Pool
  • func (p *Pool) Close() error
  • func (p *Pool) Dispatch(task Task) (Tokener, error)
• type Task
• type Tokener

Variables

var ErrPoolClosed = errors.New("pool closed")

var ErrTokenClosed = errors.New("token closed")

Types

type Pool

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

func NewPool

func NewPool(size ...int) *Pool

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) Dispatch

func (p *Pool) Dispatch(task Task) (Tokener, error)

type Task

type Task func(ctx context.Context) error

type Tokener

type Tokener interface {
	WaitWithContext(ctx context.Context) error
	Cancel()
}