coroutine

Documentation

Index

• type Concurrent
  • func NewConcurrent(max int) *Concurrent
  • func (c *Concurrent) Close()
  • func (c *Concurrent) Run(fn func())
• type Parallel
  • func NewParallel(max int) *Parallel
  • func (p *Parallel) Add(fn ...func())
  • func (p *Parallel) Wait()

Types

type Concurrent

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

func NewConcurrent

func NewConcurrent(max int) *Concurrent

func (*Concurrent) Close

func (c *Concurrent) Close()

Close the concurrent ch

func (*Concurrent) Run

func (c *Concurrent) Run(fn func())

Run runs a function in a goroutine, but limits the amount goroutines running at the same time. Warning: Please pay attention to the scope of variables in the function.

type Parallel

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

func NewParallel

func NewParallel(max int) *Parallel

func (*Parallel) Add

func (p *Parallel) Add(fn ...func())

func (*Parallel) Wait

func (p *Parallel) Wait()