(self, q, msg, go, results, shutdown=False)
| 447 | return False |
| 448 | |
| 449 | def _put(self, q, msg, go, results, shutdown=False): |
| 450 | go.wait() |
| 451 | try: |
| 452 | q.put(msg) |
| 453 | results.append(not shutdown) |
| 454 | return not shutdown |
| 455 | except self.queue.ShutDown: |
| 456 | results.append(shutdown) |
| 457 | return shutdown |
| 458 | |
| 459 | def _put_shutdown(self, q, msg, go, results): |
| 460 | return self._put(q, msg, go, results, True) |
no test coverage detected