(self, thread, t)
| 766 | return self._idle_event.wait(timeout) |
| 767 | |
| 768 | def _join_thread(self, thread, t): |
| 769 | #c cdef int cnt |
| 770 | while True: |
| 771 | try: |
| 772 | thread.join(1.0) |
| 773 | if not thread.is_alive(): |
| 774 | return thread |
| 775 | if t is not None and (_time() > t): |
| 776 | return None |
| 777 | except KeyboardInterrupt: |
| 778 | self._shutdown_children = True |
| 779 | self._shutdown = True |
| 780 | raise |
| 781 | |
| 782 | #c cpdef cleanup_children(self): |
| 783 | def cleanup_children(self): #p |