(q)
| 22 | QUEUE_SIZE = 5 |
| 23 | |
| 24 | def qfull(q): |
| 25 | return q.maxsize > 0 and q.qsize() == q.maxsize |
| 26 | |
| 27 | # A thread to run a function that unclogs a blocked Queue. |
| 28 | class _TriggerThread(threading.Thread): |
no test coverage detected
searching dependent graphs…