File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ func main() {
1616 // initial queue pool
1717 q := queue .NewPool (5 , queue .WithLogger (zerolog .New ()))
1818 // shutdown the service and notify all the worker
19- // wait all jobs are complete .
19+ // wait all jobs done .
2020 defer q .Release ()
2121
2222 // assign tasks in queue
Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ func main() {
4040 return nil
4141 }))
4242 // shutdown the service and notify all the worker
43- // wait all jobs are complete .
43+ // wait all jobs done .
4444 defer q .Release ()
4545
4646 // assign tasks in queue
@@ -58,6 +58,6 @@ func main() {
5858 // wait until all tasks done
5959 for i := 0 ; i < taskN ; i ++ {
6060 fmt .Println ("message:" , <- rets )
61- time .Sleep (50 * time .Millisecond )
61+ time .Sleep (20 * time .Millisecond )
6262 }
6363}
You can’t perform that action at this time.
0 commit comments