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