threading

Documentation

Index

• func ParallellForLoop(numWorkers int, from, to int, f func(int) error) error
• type ParallelExecutor
  • func NewParallelExecutor() *ParallelExecutor
  • func (wp *ParallelExecutor) AddWork(f func() error)
  • func (wp *ParallelExecutor) Execute() error

Functions

func ParallellForLoop

func ParallellForLoop(numWorkers int, from, to int, f func(int) error) error

Types

type ParallelExecutor

type ParallelExecutor struct {
	// contains filtered or unexported fields
}

func NewParallelExecutor

func NewParallelExecutor() *ParallelExecutor

CreateWorkerPool initializes a pool of workers to process tasks.

func (*ParallelExecutor) AddWork

func (wp *ParallelExecutor) AddWork(f func() error)

enqueue work

func (*ParallelExecutor) Execute

func (wp *ParallelExecutor) Execute() error

close work channel and finish