taskpool

type DisposeType int

type ModOption func(option *Option)

type Option struct {
	// 创建池对象时，预先开启的worker(协程)数量，如果为0，则不预先开启。只是一个小优化
	InitWorkerNum int

	// - 如果为0，则无协程数量限制。向池中添加任务时如果无空闲协程，会无条件创建新的协程。
	// - 如果不为0，则池内总协程数量达到阈值后，将不再创建新的协程。此时任务会被缓存，等待有空闲协程时才被执行。
	//   可用来控制任务的最大并发数
	MaxWorkerNum int
}

type Pool interface {
	// Go
	//
	// 向池内放入任务
	//
	// 非阻塞函数，不会等待task执行
	//
	// 注意一种场景，往Pool添加了一堆task任务，但是还没有执行到，现在想取消没有执行的任务。
	// 这种情况业务层可以在task实现中增加标志位，通过标志位决定是否执行任务。
	//
	Go(task TaskFn, param ...interface{})

	// GetCurrentStatus 获取当前的状态，注意，只是一个瞬时值
	GetCurrentStatus() Status

	// KillIdleWorkers 关闭池内所有的空闲协程
	KillIdleWorkers()

	// Dispose 完全释放池内资源，包括所有协程
	Dispose(t DisposeType)
}

type Status struct {
	TotalWorkerNum int // 总协程数量
	IdleWorkerNum  int // 空闲协程数量
	BlockTaskNum   int // 等待执行的任务数。注意，只在协程数量有最大限制的情况下，该值才可能不为0，具体见Option.MaxWorkerNum
}

type TaskFn func(param ...interface{})