taskqueue

func RunOnContextPool ¶

func RunOnContextPool(work <-chan string, completed chan<- string, pool interface {
	Go(func(context.Context) error)
	Wait() error
}, handler func(context.Context, string) error) error

For use with conc.ContextPool

func RunOnErrorPool ¶

func RunOnErrorPool(work <-chan string, completed chan<- string, pool interface {
	Go(func() error)
	Wait() error
}, handler func(string) error) error

For use with conc.ErrorPool

func RunOnPool ¶

func RunOnPool(work <-chan string, completed chan<- string, pool interface {
	Go(func())
	Wait()
}, handler func(string))

For use with conc.Pool

func RunOnResultContextPool ¶

func RunOnResultContextPool[T any](work <-chan string, completed chan<- string, pool interface {
	Go(func(context.Context) (T, error))
	Wait() ([]T, error)
}, handler func(context.Context, string) (T, error)) ([]T, error)

For use with conc.ResultContextPool

func RunOnResultErrorPool ¶

func RunOnResultErrorPool[T any](work <-chan string, completed chan<- string, pool interface {
	Go(func() (T, error))
	Wait() ([]T, error)
}, handler func(string) (T, error)) ([]T, error)

For use with conc.ResultErrorPool

func RunOnResultPool ¶

func RunOnResultPool[T any](work <-chan string, completed chan<- string, pool interface {
	Go(func() T)
	Wait() []T
}, handler func(string) T) []T

For use with conc.ResultPool

func Start ¶

func Start(tasks TaskSet) (start <-chan string, done chan<- string)

Starts a scheduler for the tasks in the task set.

Names of tasks ready to be executed are sent to the returned start channel. On completion of a task, its name must be sent to the done channel.

Tasks will only be scheduled concurrently with other tasks in the same group. This also applies to the default group indicated by an empty group name.

The scheduler closes the start channel on exit. It will exit on completion of all tasks, or if no further tasks are schedulable (i.e. there is a deadlock), or if the done channel is closed.