| 61 | self._send_signal(signal.SIGKILL) |
| 62 | |
| 63 | def _launch(self, process_obj): |
| 64 | code = 1 |
| 65 | parent_r, child_w = os.pipe() |
| 66 | child_r, parent_w = os.pipe() |
| 67 | self.pid = os.fork() |
| 68 | if self.pid == 0: |
| 69 | try: |
| 70 | atexit._clear() |
| 71 | atexit.register(util._exit_function) |
| 72 | os.close(parent_r) |
| 73 | os.close(parent_w) |
| 74 | code = process_obj._bootstrap(parent_sentinel=child_r) |
| 75 | finally: |
| 76 | atexit._run_exitfuncs() |
| 77 | os._exit(code) |
| 78 | else: |
| 79 | os.close(child_w) |
| 80 | os.close(child_r) |
| 81 | self.finalizer = util.Finalize(self, util.close_fds, |
| 82 | (parent_r, parent_w,)) |
| 83 | self.sentinel = parent_r |
| 84 | |
| 85 | def close(self): |
| 86 | if self.finalizer is not None: |