README
¶
A simple Go library to set up tasks to be executed in parallel.
package main
import (
"context"
"log"
"github.com/bep/workers"
)
func main() {
// Max 4 tasks to be executed in parallel.
w := workers.New(4)
r, _ := w.Start(context.Background())
r.Run(func() error {
return nil
})
// ... run more tasks.
if err := r.Wait(); err != nil {
log.Fatal(err)
}
}
Documentation
¶
Overview ¶
Package workers implements a parallel task executor.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Runner ¶
Runner wraps the lifecycle methods of a new task set.
Run wil block until a worker is available or the context is cancelled, and then run the given func in a new goroutine. Wait will wait for all the running goroutines to finish.
Source Files
Click to show internal directories.
Click to hide internal directories.