goPool

package

v1.1.8 Latest Latest Go to latest Published: Jun 9, 2019 License: MIT Imports: 4 Imported by: 0

Details

通用协程池任务执行器实现协程池，用以使用固定数量的 goroutine 顺序处理大量事件的场景

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	sync.Mutex     //互斥锁
	sync.WaitGroup //计数器,goroutine的个数
	// contains filtered or unexported fields
}

goroutine pool

func FromRunner(capa int, runner Runner) *Pool

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

func (this *Pool) AddExecutor()

手动创建pool执行器 add goroutine manual

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

自动保持active状态

func (this *Pool) Count() int

count may great then capa when user AddExecutor

func (this *Pool) Keepalive() int

check alive 检查pool是否是激活状态

func (this *Pool) WaitAllQuit()

return after all goroutine quit in pool 等待所有的goroutine退出

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