(self, q, go, results)
| 434 | return self._get(q, go, results, True) |
| 435 | |
| 436 | def _get_task_done(self, q, go, results): |
| 437 | go.wait() |
| 438 | try: |
| 439 | msg = q.get() |
| 440 | q.task_done() |
| 441 | results.append(True) |
| 442 | return msg |
| 443 | except self.queue.ShutDown: |
| 444 | results.append(False) |
| 445 | return False |
| 446 | |
| 447 | def _put(self, q, msg, go, results, shutdown=False): |
| 448 | go.wait() |