Documentation ¶
Index ¶
Constants ¶
View Source
const (
// DefaultParallelism is the default level of parallelism used for scheduling workloads.
DefaultParallelism = 16
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Parallelizer ¶
type Parallelizer struct {
// contains filtered or unexported fields
}
Parallelizer holds the parallelism for scheduler.
func NewParallelizer ¶
func NewParallelizer(p int) *Parallelizer
NewParallelizer returns an object holding the parallelism.
func (*Parallelizer) Until ¶
func (p *Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc)
Until parallelizes and waits until doWorkPiece is executed for all pieces.
Click to show internal directories.
Click to hide internal directories.