| 25 | import "time" |
| 26 | |
| 27 | type loopQueue struct { |
| 28 | items []worker |
| 29 | expiry []worker |
| 30 | head int |
| 31 | tail int |
| 32 | size int |
| 33 | isFull bool |
| 34 | } |
| 35 | |
| 36 | func newWorkerLoopQueue(size int) *loopQueue { |
| 37 | if size <= 0 { |
nothing calls this directly
no outgoing calls
no test coverage detected