| 17 | |
| 18 | |
| 19 | class InfoConsumer(threading.Thread): |
| 20 | def __init__(self, infoQueue: Queue): |
| 21 | super().__init__() |
| 22 | self.infoQueue = infoQueue |
| 23 | |
| 24 | def run(self): |
| 25 | while True: |
| 26 | get = self.infoQueue.get(block=True, timeout=5) |
| 27 | if get is None: |
| 28 | print("InfoConsumer: CANCEL detected") |
| 29 | return |
| 30 | filename, speed, progress, done, allDone = get |
| 31 | print(f" - {filename} - {speed}KB/s - {progress}% - {done=} - {allDone=}") |
| 32 | if allDone: |
| 33 | return |
| 34 | |
| 35 | |
| 36 | if __name__ == "__main__": |