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() {
16
16
// initial queue pool
17
17
q := queue .NewPool (5 , queue .WithLogger (zerolog .New ()))
18
18
// shutdown the service and notify all the worker
19
- // wait all jobs are complete .
19
+ // wait all jobs done .
20
20
defer q .Release ()
21
21
22
22
// assign tasks in queue
Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ func main() {
40
40
return nil
41
41
}))
42
42
// shutdown the service and notify all the worker
43
- // wait all jobs are complete .
43
+ // wait all jobs done .
44
44
defer q .Release ()
45
45
46
46
// assign tasks in queue
@@ -58,6 +58,6 @@ func main() {
58
58
// wait until all tasks done
59
59
for i := 0 ; i < taskN ; i ++ {
60
60
fmt .Println ("message:" , <- rets )
61
- time .Sleep (50 * time .Millisecond )
61
+ time .Sleep (20 * time .Millisecond )
62
62
}
63
63
}
You can’t perform that action at this time.
0 commit comments