GoPool

Documentation

Index

• type Pool
  • func FromRunner(capa int, runner Runner) *Pool
  • func NewPool(capa int, run func() (interface{}, error), ...) *Pool
  • func (this *Pool) AddExecutor()
  • func (this *Pool) AutoKeepalive(duration time.Duration)
  • func (this *Pool) Count() int
  • func (this *Pool) Keepalive() int
  • func (this *Pool) WaitAllQuit()
• type Runner

Types

type Pool

type Pool struct {
	sync.Mutex
	sync.WaitGroup
	// contains filtered or unexported fields
}

goroutine pool

func FromRunner

func FromRunner(capa int, runner Runner) *Pool

func NewPool

func NewPool(capa int,
	run func() (interface{}, error),
	quit func(*Pool, interface{}, error)) *Pool

func (*Pool) AddExecutor

func (this *Pool) AddExecutor()

add goroutine manual

func (*Pool) AutoKeepalive

func (this *Pool) AutoKeepalive(duration time.Duration)

func (*Pool) Count

func (this *Pool) Count() int

count may great then capa when user AddExecutor

func (*Pool) Keepalive

func (this *Pool) Keepalive() int

check alive

func (*Pool) WaitAllQuit

func (this *Pool) WaitAllQuit()

return after all goroutine quit in pool

type Runner

type Runner interface {
	Run() (interface{}, error)
	Quit(*Pool, interface{}, error)
}