The highest tagged major version is
v4.
package
Version:
v2.2.5
Opens a new window with list of versions in this module.
Published: Oct 24, 2019
License: MIT
Opens a new window with license information.
Imports: 2
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
func FireAndForget(maxConcurrent uint, action Action) chan<- interface{}
FireAndForget run concurrent action without taking care of output
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)
type Action func(interface{}) (interface{}, error)
Action defines a concurrent action with takes input and return output or error
Source Files
¶
Click to show internal directories.
Click to hide internal directories.