pool

Documentation

Index

• Constants
• Variables
• type Pool
  • func NewPool(capacity uint64) (*Pool, error)
  • func (p *Pool) Close()
  • func (p *Pool) GetCap() uint64
  • func (p *Pool) GetRunningWorkers() uint64
  • func (p *Pool) Put(task Task) error
• type Task

Constants

const (
	RUNNING = 1
	STOPPED = 0
)

Variables

var ErrInvalidPoolCap = errors.New("invalid pool cap")

var ErrPoolAlreadyClosed = errors.New("pool already closed")

Types

type Pool

type Pool struct {
	PanicHandler func(interface{})
	// contains filtered or unexported fields
}

func NewPool

func NewPool(capacity uint64) (*Pool, error)

func (*Pool) Close

func (p *Pool) Close()

func (*Pool) GetCap

func (p *Pool) GetCap() uint64

func (*Pool) GetRunningWorkers

func (p *Pool) GetRunningWorkers() uint64

func (*Pool) Put

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

type Task

type Task interface {
	Handler()
}