Documentation
¶
Overview ¶
Package pools contains pool and worker structs
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BusPool ¶
type BusPool struct {
// contains filtered or unexported fields
}
BusPool is a pool of workers.
func NewBusPool ¶
func NewBusPool( threadsCnt, queueSize int, wg *sync.WaitGroup, decorators ...pipelines.TaskDecorator, ) *BusPool
NewBusPool creates a pool of workers.
type Delayer ¶
type Delayer struct {
// contains filtered or unexported fields
}
Delayer is a struct for delayed tasks execution.
func NewDelayer ¶
NewDelayer is a factory method for Delayer.
type HashPool ¶
type HashPool struct {
// contains filtered or unexported fields
}
HashPool is a pool of "sticky" workers.
func NewHashPool ¶
func NewHashPool(threadsCnt, queueSize int, wg *sync.WaitGroup, hasher pipelines.Hasher, decorators ...pipelines.TaskDecorator, ) *HashPool
NewHashPool creates pool of "sticky" workers.
type Semaphore ¶
type Semaphore struct {
// contains filtered or unexported fields
}
Semaphore is a struct for tasks parallel execution.
func NewSemaphore ¶
func NewSemaphore( threadsCnt int, wg *sync.WaitGroup, decorators ...pipelines.TaskDecorator, ) *Semaphore
NewSemaphore is a factory for Semaphore.
Source Files
Click to show internal directories.
Click to hide internal directories.