//usr/lib64/python3.11/multiprocessing
23 items
NAME ↑ SIZE MODIFIED PERMS ACTIONS
.. / Parent Directory
__pycache__ — dir
2026-07-01 11:10 · rwxr-xr-x
— 2026-07-01 11:10 rwxr-xr-x
dummy — dir
2026-07-01 11:10 · rwxr-xr-x
— 2026-07-01 11:10 rwxr-xr-x
__init__.py — 916 B
2025-06-03 18:38 · rw-r--r--
916 B 2025-06-03 18:38 rw-r--r--
connection.py — 31.8 KB
2026-04-27 16:55 · rw-r--r--
31.8 KB 2026-04-27 16:55 rw-r--r--
context.py — 11.33 KB
2025-06-03 18:38 · rw-r--r--
11.33 KB 2025-06-03 18:38 rw-r--r--
forkserver.py — 11.85 KB
2025-06-03 18:38 · rw-r--r--
11.85 KB 2025-06-03 18:38 rw-r--r--
heap.py — 11.35 KB
2025-06-03 18:38 · rw-r--r--
11.35 KB 2025-06-03 18:38 rw-r--r--
managers.py — 46.57 KB
2025-06-03 18:38 · rw-r--r--
46.57 KB 2025-06-03 18:38 rw-r--r--
pool.py — 31.99 KB
2025-06-03 18:38 · rw-r--r--
31.99 KB 2025-06-03 18:38 rw-r--r--
popen_fork.py — 2.32 KB
2025-06-03 18:38 · rw-r--r--
2.32 KB 2025-06-03 18:38 rw-r--r--
popen_forkserver.py — 2.18 KB
2025-06-03 18:38 · rw-r--r--
2.18 KB 2025-06-03 18:38 rw-r--r--
popen_spawn_posix.py — 1.98 KB
2025-06-03 18:38 · rw-r--r--
1.98 KB 2025-06-03 18:38 rw-r--r--
popen_spawn_win32.py — 4.41 KB
2025-06-03 18:38 · rw-r--r--
4.41 KB 2025-06-03 18:38 rw-r--r--
process.py — 11.85 KB
2025-06-03 18:38 · rw-r--r--
11.85 KB 2025-06-03 18:38 rw-r--r--
queues.py — 11.74 KB
2025-06-03 18:38 · rw-r--r--
11.74 KB 2025-06-03 18:38 rw-r--r--
reduction.py — 9.29 KB
2025-06-03 18:38 · rw-r--r--
9.29 KB 2025-06-03 18:38 rw-r--r--
resource_sharer.py — 5.02 KB
2025-06-03 18:38 · rw-r--r--
5.02 KB 2025-06-03 18:38 rw-r--r--
resource_tracker.py — 10.09 KB
2025-06-03 18:38 · rw-r--r--
10.09 KB 2025-06-03 18:38 rw-r--r--
shared_memory.py — 18.03 KB
2025-06-03 18:38 · rw-r--r--
18.03 KB 2025-06-03 18:38 rw-r--r--
sharedctypes.py — 6.16 KB
2025-06-03 18:38 · rw-r--r--
6.16 KB 2025-06-03 18:38 rw-r--r--
spawn.py — 9.42 KB
2025-06-03 18:38 · rw-r--r--
9.42 KB 2025-06-03 18:38 rw-r--r--
synchronize.py — 12 KB
2025-06-03 18:38 · rw-r--r--
12 KB 2025-06-03 18:38 rw-r--r--
util.py — 13.93 KB
2025-06-03 18:38 · rw-r--r--
13.93 KB 2025-06-03 18:38 rw-r--r--
ONLINE
multiprocessing
23 items
19:16:21
TERMINAL FM
NAVIGATION
ACTIONS
SELECTION
Edit
Preview
Download
Rename
Copy
Chmod
Delete
import os import signal from . import util __all__ = ['Popen'] # # Start child process using fork # class Popen(object): method = 'fork' def __init__(self, process_obj): util._flush_std_streams() self.returncode = None self.finalizer = None self._launch(process_obj) def duplicate_for_child(self, fd): return fd def poll(self, flag=os.WNOHANG): if self.returncode is None: try: pid, sts = os.waitpid(self.pid, flag) except OSError: # Child process not yet created. See #1731717 # e.errno == errno.ECHILD == 10 return None if pid == self.pid: self.returncode = os.waitstatus_to_exitcode(sts) return self.returncode def wait(self, timeout=None): if self.returncode is None: if timeout is not None: from multiprocessing.connection import wait if not wait([self.sentinel], timeout): return None # This shouldn't block if wait() returned successfully. return self.poll(os.WNOHANG if timeout == 0.0 else 0) return self.returncode def _send_signal(self, sig): if self.returncode is None: try: os.kill(self.pid, sig) except ProcessLookupError: pass except OSError: if self.wait(timeout=0.1) is None: raise def terminate(self): self._send_signal(signal.SIGTERM) def kill(self): self._send_signal(signal.SIGKILL) def _launch(self, process_obj): code = 1 parent_r, child_w = os.pipe() child_r, parent_w = os.pipe() self.pid = os.fork() if self.pid == 0: try: os.close(parent_r) os.close(parent_w) code = process_obj._bootstrap(parent_sentinel=child_r) finally: os._exit(code) else: os.close(child_w) os.close(child_r) self.finalizer = util.Finalize(self, util.close_fds, (parent_r, parent_w,)) self.sentinel = parent_r def close(self): if self.finalizer is not None: self.finalizer()