workers

Documentation

Index

• func AddTask(task func())
• func RestartWorkers()
• func RunWorkers()
• func SetWorkersLimit(limit int)
• func StopWorkers()

Functions

func AddTask

func AddTask(task func())

func RestartWorkers

func RestartWorkers()

RestartWorkers stops the current worker loop and starts it again.

func RunWorkers

func RunWorkers()

RunWorkers starts a managed worker loop for the given task if one is not already running. Each started task still respects the configured worker pool limit.

func SetWorkersLimit

func SetWorkersLimit(limit int)

SetWorkersLimit sets the maximum number of concurrent workers for future runs. Non-positive limits fall back to the default worker limit.

func StopWorkers

func StopWorkers()

StopWorkers stops the currently running worker loop, if any.