goq

goq is a simple queue manager library

Installation

If using go modules.

go get -u github.com/pureugong/goq

Getting Started

// 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()

License

Released under the MIT License