(run_flag, queue, recv, producer)
| 71 | |
| 72 | # called by the consumer thread |
| 73 | def consume(run_flag, queue, recv, producer): |
| 74 | # consume items while running |
| 75 | while run_flag[0]: |
| 76 | do_consume(queue, recv) |
| 77 | # empty the queue to allow maximum room |
| 78 | while not queue.empty(): |
| 79 | do_consume(queue, recv) |
| 80 | # wait for the producer to end |
| 81 | producer.join() |
| 82 | # consume any other items that might have been produced |
| 83 | while not queue.empty(): |
| 84 | do_consume(queue, recv) |
| 85 | |
| 86 | # executes one consumption operation |
| 87 | def do_consume(queue, recv): |
nothing calls this directly
no test coverage detected