README
¶
pool
goroutine pool
注意
池中的任务需要考虑通用性，所以使用了反射(reflect)，也就会有一定的性能损失。
如果对性能要求较高，建议根据实际需求将任务函数和参数重写。
如：
type handle func (a, b string) string
type Task struct {
handle handle
a string
b string
}
func NewTask(f handle, a, b string) Task {
return Task{
handle: f,
a: a,
b: b
}
}
...
for task := range p.chTask {
task.handle(task.a, task.b)
}
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // return if pool size <= 0 ErrInvalidPoolCap = errors.New("invalid pool cap") // put task but pool already closed ErrPoolAlreadyClosed = errors.New("pool already closed") // only the error type can be captured and processed ErrUnkownType = errors.New("recover only allows error type, but an unknown type is received") // thrown when `Handle` is not a function type ErrNotFunc = errors.New("`Handle` only accepts function types") )
errors
Functions ¶
This section is empty.
Types ¶
type Pool ¶
Pool task pool
func (*Pool) BlockPanic ¶
BlockPanic decides whether to panic when a goroutine throws an exception
func (*Pool) GetRunningWorkers ¶
GetRunningWorkers get running workers
Source Files
Click to show internal directories.
Click to hide internal directories.