(self)
| 256 | self.out_queue = out_queue |
| 257 | |
| 258 | def run(self): |
| 259 | while True: |
| 260 | try: |
| 261 | item = self.in_queue.get() |
| 262 | except ShutDown: |
| 263 | return |
| 264 | else: |
| 265 | result = self.func(item) |
| 266 | self.out_queue.put(result) |
| 267 | self.in_queue.task_done() |
| 268 | |
| 269 | |
| 270 | print("Example 19") |