(self)
| 642 | self._queue = queue |
| 643 | |
| 644 | def run(self): |
| 645 | while True: |
| 646 | obj = self._queue.get() |
| 647 | if obj == "finish": |
| 648 | break |
| 649 | |
| 650 | print("processed", obj.value) |
| 651 | obj.event.set() |
| 652 | |
| 653 | class NotificationObject(object): |
| 654 | def __init__(self, value): |