example

README

$ go run main.go
queue pm create ! consumerNumber: 1 
queue rd create ! consumerNumber: 2 
2023/03/06 01:56:17 pm send task: 0
2023/03/06 01:56:17 pm send task: 1
2023/03/06 01:56:17 rd send task: 0
2023/03/06 01:56:17 pm process task: 0
2023/03/06 01:56:17 pm send task: 2
2023/03/06 01:56:17 pm send task: 3
2023/03/06 01:56:17 rd send task: 1
2023/03/06 01:56:17 rd process task: 0
2023/03/06 01:56:17 pm send task: 4
2023/03/06 01:56:17 rd send task: 2
2023/03/06 01:56:17 rd process task: 1
2023/03/06 01:56:17 pm send task: 5
2023/03/06 01:56:17 pm send task: 6
2023/03/06 01:56:17 pm send task: 7
2023/03/06 01:56:17 pm send task: 8
2023/03/06 01:56:17 rd send task: 3
2023/03/06 01:56:17 rd send task: 4
2023/03/06 01:56:17 rd send task: 5
2023/03/06 01:56:17 pm send task: 9
2023/03/06 01:56:17 rd send task: 6
2023/03/06 01:56:17 rd send task: 7
2023/03/06 01:56:17 rd send task: 8
2023/03/06 01:56:17 rd send task: 9
2023/03/06 01:56:18 before runtime.NumGoroutine():  22
2023/03/06 01:56:19 before runtime.NumGoroutine():  22
2023/03/06 01:56:19 pm finish task: 0
2023/03/06 01:56:19 pm process task: 1
2023/03/06 01:56:19 rd finish task: 0
2023/03/06 01:56:19 rd process task: 2
2023/03/06 01:56:19 rd finish task: 1
2023/03/06 01:56:19 rd process task: 3
2023/03/06 01:56:20 before runtime.NumGoroutine():  19
2023/03/06 01:56:21 before runtime.NumGoroutine():  19
2023/03/06 01:56:21 rd finish task: 2
2023/03/06 01:56:21 rd process task: 4
2023/03/06 01:56:21 pm finish task: 1
2023/03/06 01:56:21 pm process task: 2
2023/03/06 01:56:21 rd finish task: 3
2023/03/06 01:56:21 rd process task: 5
2023/03/06 01:56:22 After runtime.NumGoroutine():  16
2023/03/06 01:56:22 execute CloseAll
close after waiting for 6 tasks for queue "rd"
close after waiting for 8 tasks for queue "pm"
2023/03/06 01:56:22 before runtime.NumGoroutine():  18
close after waiting for 6 tasks for queue "rd"
2023/03/06 01:56:23 before runtime.NumGoroutine():  18
close after waiting for 8 tasks for queue "pm"
2023/03/06 01:56:23 pm finish task: 2
2023/03/06 01:56:23 pm process task: 3
2023/03/06 01:56:23 rd finish task: 5
2023/03/06 01:56:23 rd finish task: 4
2023/03/06 01:56:23 rd process task: 7
2023/03/06 01:56:23 rd process task: 6
close after waiting for 4 tasks for queue "rd"
2023/03/06 01:56:24 before runtime.NumGoroutine():  15
close after waiting for 7 tasks for queue "pm"
close after waiting for 4 tasks for queue "rd"
2023/03/06 01:56:25 before runtime.NumGoroutine():  15
close after waiting for 7 tasks for queue "pm"
2023/03/06 01:56:25 pm finish task: 3
2023/03/06 01:56:25 pm process task: 4
2023/03/06 01:56:25 rd finish task: 6
2023/03/06 01:56:25 rd process task: 8
2023/03/06 01:56:25 rd finish task: 7
2023/03/06 01:56:25 rd process task: 9
close after waiting for 2 tasks for queue "rd"
2023/03/06 01:56:26 before runtime.NumGoroutine():  12
close after waiting for 6 tasks for queue "pm"
close after waiting for 2 tasks for queue "rd"
2023/03/06 01:56:27 before runtime.NumGoroutine():  12
close after waiting for 6 tasks for queue "pm"
2023/03/06 01:56:27 pm finish task: 4
2023/03/06 01:56:27 pm process task: 5
2023/03/06 01:56:27 rd finish task: 9
2023/03/06 01:56:27 rd finish task: 8
queue rd close !
2023/03/06 01:56:28 before runtime.NumGoroutine():  8
close after waiting for 5 tasks for queue "pm"
2023/03/06 01:56:29 before runtime.NumGoroutine():  8
2023/03/06 01:56:29 pm finish task: 5
2023/03/06 01:56:29 pm process task: 6
close after waiting for 4 tasks for queue "pm"
2023/03/06 01:56:30 before runtime.NumGoroutine():  7
close after waiting for 4 tasks for queue "pm"
2023/03/06 01:56:31 pm finish task: 6
2023/03/06 01:56:31 pm process task: 7
2023/03/06 01:56:31 before runtime.NumGoroutine():  7
close after waiting for 3 tasks for queue "pm"
2023/03/06 01:56:32 before runtime.NumGoroutine():  6
close after waiting for 3 tasks for queue "pm"
2023/03/06 01:56:33 before runtime.NumGoroutine():  6
2023/03/06 01:56:33 pm finish task: 7
2023/03/06 01:56:33 pm process task: 8
close after waiting for 2 tasks for queue "pm"
2023/03/06 01:56:34 before runtime.NumGoroutine():  5
close after waiting for 2 tasks for queue "pm"
2023/03/06 01:56:35 before runtime.NumGoroutine():  5
2023/03/06 01:56:35 pm finish task: 8
2023/03/06 01:56:35 pm process task: 9
close after waiting for 1 tasks for queue "pm"
2023/03/06 01:56:36 before runtime.NumGoroutine():  4
close after waiting for 1 tasks for queue "pm"
2023/03/06 01:56:37 pm finish task: 9
2023/03/06 01:56:37 before runtime.NumGoroutine():  4
queue pm close !
2023/03/06 01:56:38 before runtime.NumGoroutine():  2
2023/03/06 01:56:38 dispatch again
2023/03/06 01:56:38 rd send task: 0
2023/03/06 01:56:38 rd send task: 1
2023/03/06 01:56:38 rd send task: 2
2023/03/06 01:56:38 pm send task: 0
2023/03/06 01:56:38 pm send task: 1
2023/03/06 01:56:38 rd send task: 3
2023/03/06 01:56:38 rd send task: 4
2023/03/06 01:56:38 rd send task: 5
2023/03/06 01:56:38 rd send task: 6
2023/03/06 01:56:38 pm send task: 2
2023/03/06 01:56:38 pm send task: 3
2023/03/06 01:56:38 pm send task: 4
2023/03/06 01:56:38 rd send task: 7
2023/03/06 01:56:38 rd send task: 8
2023/03/06 01:56:38 rd send task: 9
2023/03/06 01:56:38 pm send task: 5
2023/03/06 01:56:38 pm send task: 6
2023/03/06 01:56:38 pm send task: 7
2023/03/06 01:56:38 pm send task: 8
2023/03/06 01:56:38 pm send task: 9
2023/03/06 01:56:39 before runtime.NumGoroutine():  2
2023/03/06 01:56:40 before runtime.NumGoroutine():  2
2023/03/06 01:56:41 before runtime.NumGoroutine():  2
2023/03/06 01:56:42 before runtime.NumGoroutine():  2
2023/03/06 01:56:43 timeout runtime.NumGoroutine():  2
2023/03/06 01:56:43 finish ...