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
	PAUSED  = 2
	STOPPED = 3
)

Variables

var (
	// ErrInvalidPoolCap return if pool size <= 0
	ErrInvalidPoolCap = errors.New("invalid pool cap")
	// ErrPoolAlreadyClosed put task but pool already closed
	ErrPoolAlreadyClosed = errors.New("pool already closed")
)

Types

type Pool

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

Pool task pool

func NewPool

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

NewPool init pool

func (*Pool) Close

func (p *Pool) Close()

Close close pool graceful

func (*Pool) GetCap

func (p *Pool) GetCap() uint64

GetCap get capacity

func (*Pool) GetRunningWorkers

func (p *Pool) GetRunningWorkers() uint64

GetRunningWorkers get running workers

func (*Pool) Put

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

Put put a task to pool

type Task

type Task struct {
	Handler func(v ...interface{})
	Params  []interface{}
}

Task task to-do