concurrent

Documentation

Index

• type ConcurrentCalcStruc
  • func ConcurrentCalcStrucNew(cpuCount int, callBack func(item interface{})) *ConcurrentCalcStruc
  • func (ccs *ConcurrentCalcStruc) Run(items []interface{})
  • func (ccs *ConcurrentCalcStruc) StringSliceToIfaceSlice(inStr []string) []interface{}
  • func (ccs *ConcurrentCalcStruc) Wait()

Types

type ConcurrentCalcStruc

type ConcurrentCalcStruc struct {
	CpuCount,

	Count int

	Callback func(item interface{})
	// contains filtered or unexported fields
}

ConcurrentCalcStruc: structure to hold information and callback function to use while doing concurrent operations

func ConcurrentCalcStrucNew

func ConcurrentCalcStrucNew(cpuCount int, callBack func(item interface{})) *ConcurrentCalcStruc

ConcurrentCalcStrucNew: Create new structure

func (*ConcurrentCalcStruc) Run

func (ccs *ConcurrentCalcStruc) Run(items []interface{})

Run: Start concurrent computing operations

func (*ConcurrentCalcStruc) StringSliceToIfaceSlice

func (ccs *ConcurrentCalcStruc) StringSliceToIfaceSlice(inStr []string) []interface{}

StringSliceToIfaceSlice: Convert string slice to interface slice

func (*ConcurrentCalcStruc) Wait

func (ccs *ConcurrentCalcStruc) Wait()

Wait: Until operations done