workpool

type JobBag struct {
	JobFunc WorkFunc
	Params  []interface{}
}

type WorkFunc func(...interface{})

type WorkPool interface {
	// SubmitJob 提交任务
	SubmitJob(job ...*JobBag)
	// GetPoolIdleSize get pool idle size
	GetPoolIdleSize() int
	// GetJobQueueIdleSize 获取job队列空闲成都
	GetJobQueueIdleSize() int
	// ShutDownPool 关闭工作池
	ShutDownPool()
	// IsShutDownPool 获取是否关闭
	IsShutDownPool() bool
	// IsFinished get pool execute info, true is finished false is running
	IsFinished() bool

	// OpenFinishNotify 开启任务完成通知，开启之后需要 WatchFinishNotify 监听，否则死锁
	OpenFinishNotify()
	// WatchFinishNotify 监听通知，开启之后需要监听，否则死锁
	WatchFinishNotify() <-chan struct{}
}