concurrent

Documentation

Index

• func FireAndForget(maxConcurrent uint, action Action) chan<- interface{}
• func Run(maxConcurrent uint, action Action, onSuccess func(interface{}), ...) chan<- interface{}
• type Action

Functions

func FireAndForget

func FireAndForget(maxConcurrent uint, action Action) chan<- interface{}

FireAndForget run concurrent action without taking care of output

func Run

func Run(maxConcurrent uint, action Action, onSuccess func(interface{}), onError func(error)) chan<- interface{}

Run create a pool of goroutines for executing action with concurrency limits (default to NumCPU)

Types

type Action

type Action func(interface{}) (interface{}, error)

Action defines a concurrent action with takes input and return output or error