parallel

Documentation

Index

• type Batch
• type Batches
  • func NewBatches(size, batch int) Batches
  • func (b Batches) AsChannel() <-chan Batch
  • func (b Batches) Run(threads int, iteration Iterator) timer.Result
• type Iterator

Types

type Batch

type Batch struct {
	Start, End, ID int
}

type Batches

type Batches struct {
	Batches    []Batch
	Iterations int
	BatchSize  int
}

func NewBatches

func NewBatches(size, batch int) Batches

func (Batches) AsChannel

func (b Batches) AsChannel() <-chan Batch

func (Batches) Run

func (b Batches) Run(threads int, iteration Iterator) timer.Result

type Iterator

type Iterator func(thread int, batch Batch) error