pool

Documentation

Index

• type Pool
  • func New(burst int32, taskFunc TaskHandler) *Pool
  • func (p *Pool) Error() error
  • func (p *Pool) Put(task interface{})
  • func (p *Pool) Stop()
  • func (p *Pool) Wait() error
• type TaskHandler

Types

type Pool

type Pool struct {
	Burst    int32
	TaskFunc TaskHandler
	// contains filtered or unexported fields
}

func New

func New(burst int32, taskFunc TaskHandler) *Pool

func (*Pool) Error

func (p *Pool) Error() error

func (*Pool) Put

func (p *Pool) Put(task interface{})

func (*Pool) Stop

func (p *Pool) Stop()

func (*Pool) Wait

func (p *Pool) Wait() error

type TaskHandler

type TaskHandler func(task interface{}) error