concurrency

Documentation

Overview

CODE ATTRIBUTION: https://github.com/korovkin/limiter Modified to accept a parameter to the executed job

Index

• Constants
• type Limiter
  • func NewLimiter(limit int) *Limiter
  • func (c *Limiter) Execute(job func(param interface{}), param interface{}) int
  • func (c *Limiter) Wait()

Constants

const (
	// DefaultLimit is the default concurrency limit.
	DefaultLimit = 100
)

Types

type Limiter

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

Limiter object.

func NewLimiter

func NewLimiter(limit int) *Limiter

NewLimiter allocates a new ConcurrencyLimiter.

func (*Limiter) Execute

func (c *Limiter) Execute(job func(param interface{}), param interface{}) int

Execute adds a function to the execution queue. if num of go routines allocated by this instance is < limit launch a new go routine to execute job else wait until a go routine becomes available.

func (*Limiter) Wait

func (c *Limiter) Wait()

Wait will block all the previously Executed jobs completed running.

IMPORTANT: calling the Wait function while keep calling Execute leads to

un-desired race conditions