coroutines

Documentation

Index

• func Parallel(max int, fns ...func())
• func ParallelWait(max int, fns ...func())
• func Run(fns ...func())
• func Wait(fns ...func())
• type Worker
  • func NewWorker(max int) *Worker
  • func (s *Worker) Close()
  • func (s *Worker) Push(fns ...func())
  • func (s *Worker) Wait()

Functions

func Parallel

func Parallel(max int, fns ...func())

func ParallelWait

func ParallelWait(max int, fns ...func())

func Run

func Run(fns ...func())

func Wait

func Wait(fns ...func())

Types

type Worker

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

func NewWorker

func NewWorker(max int) *Worker

NewWorker creates a new worker for running tasks in parallel. The max parameter specifies the maximum number of goroutines that can run at the same time.

Example:

w := coroutines.NewWorker(10)
defer w.Close()
w.Push(func() {
  // do something
}...)
w.Wait()

func (*Worker) Close

func (s *Worker) Close()

func (*Worker) Push

func (s *Worker) Push(fns ...func())

func (*Worker) Wait

func (s *Worker) Wait()