parallelize

Aug 24, 2020

Changes in this version

+ type MultiParamWork struct

+ Data []interface{}

+ Func func(...interface{}) (interface{}, error)

+ func (mpw *MultiParamWork) Work() (interface{}, error)

+ type Runner struct

+ func NewBoundedRunner(workSize, parallelCount int) *Runner

+ func NewFixedBoundedRunner(workSize int, ioBound bool) *Runner

+ func NewUnboundedRunner(workSize int) *Runner

+ func (r *Runner) GetResult() ([]interface{}, error)

+ func (r *Runner) SubmitWork(wrk Work)

+ type SingleParamWork struct

+ Data interface{}

+ Func func(data interface{}) (interface{}, error)

+ func (spw *SingleParamWork) Work() (interface{}, error)

+ type StatelessFunc func() (interface{}, error)

+ func (sf StatelessFunc) Work() (interface{}, error)

+ type ThreeParamWork struct

+ Data1 interface{}

+ Data2 interface{}

+ Data3 interface{}

+ Func func(data1 interface{}, data2 interface{}, data3 interface{}) (interface{}, error)

+ func (tpw *ThreeParamWork) Work() (interface{}, error)

+ type TwoParamWork struct

+ Data1 interface{}

+ Data2 interface{}

+ Func func(data1 interface{}, data2 interface{}) (interface{}, error)

+ func (tpw *TwoParamWork) Work() (interface{}, error)

+ type Work interface

+ Work func() (interface{}, error)