RunListQueue start running list queues ,specify the number of worker threads
(maxThread int)
| 24 | // RunListQueue start running list queues |
| 25 | // ,specify the number of worker threads |
| 26 | func RunListQueue(maxThread int) { |
| 27 | if internalQueue == nil { |
| 28 | internalQueue = NewListQueue(maxThread) |
| 29 | } |
| 30 | internalQueue.Run() |
| 31 | } |
| 32 | |
| 33 | // Push put the executable task into the queue |
| 34 | func Push(job Jober) { |
nothing calls this directly
no test coverage detected