README
¶
Chalk 
Quickly and easily create a pool of go routines. Create as many "queues" as you want, each with their own number of go routines ready to do your bidding.
Installation
$ go get https://github.com/markbates/chalk
Usage
// create a pool of 10 go routines
c := chalk.New(10)
c.Tasks <- func() error {
// do some work here
return nil
}
// handle err
c.Tasks <- func() error {
return errors.New("boom!")
}
err := <-c.Errors
// wait for all of the workers to finish
c.Wait()
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Chalk ¶
type Chalk struct {
*sync.WaitGroup
// Tasks channel receives `Task` functions and
// adds them to the pool.
Tasks chan Task
// Errors handles communication of errors that may
// occur when running a `Task` in the pool.
Errors chan error
}
Chalk wraps the `sync.WaitGroup` and the channels used to add tasks to the pool and return errors for the tasks in the pool.
Source Files
Click to show internal directories.
Click to hide internal directories.