//usr/lib64/python3.9/multiprocessing
23 items
NAME ↑ SIZE MODIFIED PERMS ACTIONS
.. / Parent Directory
__pycache__ — dir
2026-06-03 15:44 · rwxr-xr-x
— 2026-06-03 15:44 rwxr-xr-x
dummy — dir
2026-06-03 15:44 · rwxr-xr-x
— 2026-06-03 15:44 rwxr-xr-x
__init__.py — 916 B
2025-10-31 18:40 · rw-r--r--
916 B 2025-10-31 18:40 rw-r--r--
connection.py — 31.11 KB
2026-04-27 17:28 · rw-r--r--
31.11 KB 2026-04-27 17:28 rw-r--r--
context.py — 10.99 KB
2025-10-31 18:40 · rw-r--r--
10.99 KB 2025-10-31 18:40 rw-r--r--
forkserver.py — 11.86 KB
2025-10-31 18:40 · rw-r--r--
11.86 KB 2025-10-31 18:40 rw-r--r--
heap.py — 11.35 KB
2025-10-31 18:40 · rw-r--r--
11.35 KB 2025-10-31 18:40 rw-r--r--
managers.py — 46.19 KB
2025-10-31 18:40 · rw-r--r--
46.19 KB 2025-10-31 18:40 rw-r--r--
pool.py — 31.79 KB
2025-10-31 18:40 · rw-r--r--
31.79 KB 2025-10-31 18:40 rw-r--r--
popen_fork.py — 2.32 KB
2025-10-31 18:40 · rw-r--r--
2.32 KB 2025-10-31 18:40 rw-r--r--
popen_forkserver.py — 2.18 KB
2025-10-31 18:40 · rw-r--r--
2.18 KB 2025-10-31 18:40 rw-r--r--
popen_spawn_posix.py — 1.98 KB
2025-10-31 18:40 · rw-r--r--
1.98 KB 2025-10-31 18:40 rw-r--r--
popen_spawn_win32.py — 3.92 KB
2025-10-31 18:40 · rw-r--r--
3.92 KB 2025-10-31 18:40 rw-r--r--
process.py — 11.72 KB
2025-10-31 18:40 · rw-r--r--
11.72 KB 2025-10-31 18:40 rw-r--r--
queues.py — 11.74 KB
2025-10-31 18:40 · rw-r--r--
11.74 KB 2025-10-31 18:40 rw-r--r--
reduction.py — 9.29 KB
2025-10-31 18:40 · rw-r--r--
9.29 KB 2025-10-31 18:40 rw-r--r--
resource_sharer.py — 5.01 KB
2025-10-31 18:40 · rw-r--r--
5.01 KB 2025-10-31 18:40 rw-r--r--
resource_tracker.py — 8.41 KB
2025-10-31 18:40 · rw-r--r--
8.41 KB 2025-10-31 18:40 rw-r--r--
shared_memory.py — 17.96 KB
2025-10-31 18:40 · rw-r--r--
17.96 KB 2025-10-31 18:40 rw-r--r--
sharedctypes.py — 6.16 KB
2025-10-31 18:40 · rw-r--r--
6.16 KB 2025-10-31 18:40 rw-r--r--
spawn.py — 9.08 KB
2025-10-31 18:40 · rw-r--r--
9.08 KB 2025-10-31 18:40 rw-r--r--
synchronize.py — 11.34 KB
2025-10-31 18:40 · rw-r--r--
11.34 KB 2025-10-31 18:40 rw-r--r--
util.py — 13.68 KB
2025-10-31 18:40 · rw-r--r--
13.68 KB 2025-10-31 18:40 rw-r--r--
ONLINE
multiprocessing
23 items
00:56:17
TERMINAL FM
NAVIGATION
ACTIONS
SELECTION
Edit
Preview
Download
Rename
Copy
Chmod
Delete
import io import os from .context import reduction, set_spawning_popen if not reduction.HAVE_SEND_HANDLE: raise ImportError('No support for sending fds between processes') from . import forkserver from . import popen_fork from . import spawn from . import util __all__ = ['Popen'] # # Wrapper for an fd used while launching a process # class _DupFd(object): def __init__(self, ind): self.ind = ind def detach(self): return forkserver.get_inherited_fds()[self.ind] # # Start child process using a server process # class Popen(popen_fork.Popen): method = 'forkserver' DupFd = _DupFd def __init__(self, process_obj): self._fds = [] super().__init__(process_obj) def duplicate_for_child(self, fd): self._fds.append(fd) return len(self._fds) - 1 def _launch(self, process_obj): prep_data = spawn.get_preparation_data(process_obj._name) buf = io.BytesIO() set_spawning_popen(self) try: reduction.dump(prep_data, buf) reduction.dump(process_obj, buf) finally: set_spawning_popen(None) self.sentinel, w = forkserver.connect_to_new_process(self._fds) # Keep a duplicate of the data pipe's write end as a sentinel of the # parent process used by the child process. _parent_w = os.dup(w) self.finalizer = util.Finalize(self, util.close_fds, (_parent_w, self.sentinel)) with open(w, 'wb', closefd=True) as f: f.write(buf.getbuffer()) self.pid = forkserver.read_signed(self.sentinel) def poll(self, flag=os.WNOHANG): if self.returncode is None: from multiprocessing.connection import wait timeout = 0 if flag == os.WNOHANG else None if not wait([self.sentinel], timeout): return None try: self.returncode = forkserver.read_signed(self.sentinel) except (OSError, EOFError): # This should not happen usually, but perhaps the forkserver # process itself got killed self.returncode = 255 return self.returncode