parallel

Documentation

Index

• func NewBounedRunner(maxParallel int, failFast bool) *runner
• func NewRunner(maxParallel int, capacity uint, failFast bool) *runner
• type OnErrorFunc
• type Runner
• type TaskFunc

Functions

func NewBounedRunner

func NewBounedRunner(maxParallel int, failFast bool) *runner

Create a new single capacity runner - a runner we can only add tasks to as long as there is a free goroutine in the Run() loop to handle it. maxParallel - number of go routines for task processing, maxParallel always will be a positive number. failFast - if set to true the runner will stop on first error.

func NewRunner

func NewRunner(maxParallel int, capacity uint, failFast bool) *runner

Create a new capacity runner - a runner we can add tasks to without blocking as long as the capacity is not reached. maxParallel - number of go routines for task processing, maxParallel always will be a positive number. acceptBeforeBlocking - number of tasks that can be added until a free processing goruntine is needed. failFast - is set to true the will stop on first error.

Types

type OnErrorFunc

type OnErrorFunc func(error)

type Runner

type Runner interface {
	AddTask(TaskFunc) (int, error)
	AddTaskWithError(TaskFunc, OnErrorFunc) (int, error)
	Run()
	Done()
	Cancel()
	Errors() map[int]error
	ActiveThreads() uint32
	OpenThreads() int
	IsStarted() bool
	SetMaxParallel(int)
	TotalTasksInQueue() uint32
}

type TaskFunc

type TaskFunc func(int) error