concurrencylimiter

Documentation

Index

• Variables
• func Do(f func() error) error
• func Init(size int, d ...time.Duration)
• func ScheduleWork(uw Worker)
• func StartWorkers()
• func StopWorkers()
• type Worker

Variables

var (
	Size int
)

Functions

func Do

func Do(f func() error) error

Do calls f with the limited concurrency.

func Init

func Init(size int, d ...time.Duration)

Init initializes concurrencylimiter.

Init must be called after flag.Parse call.

func ScheduleWork

func ScheduleWork(uw Worker)

ScheduleUnmarshalWork schedules uw to run in the worker pool.

It is expected that StartUnmarshalWorkers is already called.

func StartWorkers

func StartWorkers()

StartWorkers starts unmarshal workers.

func StopWorkers

func StopWorkers()

StopWorkers stops unmarshal workers.

No more calles to ScheduleWork are allowed after calling stopWorkers

Types

type Worker

type Worker interface {
	// Do must implement CPU-bound work.
	Do()
}

Worker is a unit of unmarshal work.