concurrencylimiter

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