We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 14e749b commit c37246fCopy full SHA for c37246f
README.md
@@ -209,16 +209,10 @@ func main() {
209
)
210
211
// define the queue
212
- q, err := queue.NewQueue(
213
- queue.WithWorkerCount(10),
+ q := queue.NewPool(
+ 5,
214
queue.WithWorker(w),
215
216
- if err != nil {
217
- log.Fatal(err)
218
- }
219
-
220
- // start the five worker
221
- q.Start()
222
223
// assign tasks in queue
224
for i := 0; i < taskN; i++ {
0 commit comments