goq is a simple queue manager library
If using go modules.
go get -u github.com/pureugong/goq// 1. init goq manager
manager := goq.NewManager(ctx, 1, nil)
// 2. init goq workers
manager.InitWorkers(10, func() goq.Worker {
return NewWorkerSample()
})
// 3. enqueue tasks
for i := 0; i < 100; i++ {
manager.Enqueue(i)
}
// 4. wait
manager.Wait()Released under the MIT License