misc

Documentation

Index

• Constants
• type ConcurrencyLimiter
  • func NewConcurrencyLimiter(limit int) *ConcurrencyLimiter
  • func (c *ConcurrencyLimiter) Execute(job func())
  • func (c *ConcurrencyLimiter) ExecuteIndex(index int, job func(numb int))
  • func (c *ConcurrencyLimiter) Loop(n int, job func(o int))
  • func (c *ConcurrencyLimiter) Wait()
• type Timeout
  • func (t *Timeout) Release()
  • func (t *Timeout) Run(seconds int, callback func())

Constants

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

Types

type ConcurrencyLimiter

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

ConcurrencyLimiter object

func NewConcurrencyLimiter

func NewConcurrencyLimiter(limit int) *ConcurrencyLimiter

NewConcurrencyLimiter allocates a new ConcurrencyLimiter

func (*ConcurrencyLimiter) Execute

func (c *ConcurrencyLimiter) Execute(job func())

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 (*ConcurrencyLimiter) ExecuteIndex

func (c *ConcurrencyLimiter) ExecuteIndex(index int, job func(numb int))

ExecuteIndex ExecuteIndex

func (*ConcurrencyLimiter) Loop

func (c *ConcurrencyLimiter) Loop(n int, job func(o int))

func (*ConcurrencyLimiter) Wait

func (c *ConcurrencyLimiter) 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

type Timeout

type Timeout struct {
	Released bool
	Occured  bool
}

func (*Timeout) Release

func (t *Timeout) Release()

func (*Timeout) Run

func (t *Timeout) Run(seconds int, callback func())