gopool

Documentation

Index

• Variables
• type Pool
  • func NewPool(size, queue int) (*Pool, error)
  • func (p *Pool) Schedule(job func())
  • func (p *Pool) ScheduleTimeout(timeout time.Duration, job func()) error

Variables

var ErrScheduleTimeout = fmt.Errorf("schedule timeout")

Types

type Pool

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

func NewPool

func NewPool(size, queue int) (*Pool, error)

func (*Pool) Schedule

func (p *Pool) Schedule(job func())

func (*Pool) ScheduleTimeout

func (p *Pool) ScheduleTimeout(timeout time.Duration, job func()) error