Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor interface {
Start(worker *Worker)
}
Executor is the unit of work that executes a task.
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool manages and limits the number of concurrent Worker.
func Initialize ¶
Initialize creates a new Pool with a name and the number of parallel workers it will use.
func (*Pool) ActiveWorkers ¶
ActiveWorkers gives the number of active workers on the Pool.
func (*Pool) AppendExecutor ¶
AppendExecutor adds a new Executor to the queue of Executor to be processed.
Click to show internal directories.
Click to hide internal directories.