To install the package, run:
go get github.com/go-zoox/jobqueue
import (
"testing"
"github.com/go-zoox/jobqueue"
)
func main(t *testing.T) {
q := New(runtime.NumCPU())
q.Start()
defer q.Stop()
for i := 0; i < 10; i++ {
q.AddJob(&NewJob(func() {
fmt.Println("Process Job")
}))
}
}
- dirkaholic/kyoo - Unlimited job queue for go, using a pool of concurrent workers processing the job queue entries
- go-zoox/cocurrent - A Simple Goroutine Limit Pool
- go-zoox/waitgroup - Parallel-Controlled WaitGroup
- go-zoox/promise - JavaScript Promise Like with Goroutines
GoZoox is released under the MIT License.