Documentation
¶
Overview ¶
Package concurrentqueuer defines a queuer.Interface that runs several workers concurrently on a queue
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queuer ¶
type Queuer struct {
Length int // Max queue length
Workers int // Number of concurrent workers
// contains filtered or unexported fields
}
Queuer is a queuer.Interface that runs several workers concurrently on a queue.
func (*Queuer) Push ¶
Push attempts to add an item to the queue. On failure, returns queuer.ErrDuplicate or queuer.ErrFull.
Source Files
Click to show internal directories.
Click to hide internal directories.