Current Path: > > > usr > lib64 > python3.6 > multiprocessing
Operation : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64 Software : Apache Server IP : 162.0.232.56 | Your IP: 216.73.216.111 Domains : 1034 Domain(s) Permission : [ 0755 ]
Name | Type | Size | Last Modified | Actions |
---|---|---|---|---|
__pycache__ | Directory | - | - | |
dummy | Directory | - | - | |
__init__.py | File | 923 bytes | December 23 2018 21:37:14. | |
connection.py | File | 31062 bytes | July 01 2025 22:09:53. | |
context.py | File | 10917 bytes | December 23 2018 21:37:14. | |
forkserver.py | File | 8694 bytes | December 23 2018 21:37:14. | |
heap.py | File | 8319 bytes | December 23 2018 21:37:14. | |
managers.py | File | 38151 bytes | December 23 2018 21:37:14. | |
pool.py | File | 26059 bytes | December 23 2018 21:37:14. | |
popen_fork.py | File | 2307 bytes | December 23 2018 21:37:14. | |
popen_forkserver.py | File | 1956 bytes | December 23 2018 21:37:14. | |
popen_spawn_posix.py | File | 1904 bytes | December 23 2018 21:37:14. | |
popen_spawn_win32.py | File | 2999 bytes | December 23 2018 21:37:14. | |
process.py | File | 9211 bytes | December 23 2018 21:37:14. | |
queues.py | File | 10763 bytes | December 23 2018 21:37:14. | |
reduction.py | File | 9226 bytes | December 23 2018 21:37:14. | |
resource_sharer.py | File | 5325 bytes | December 23 2018 21:37:14. | |
semaphore_tracker.py | File | 5394 bytes | December 23 2018 21:37:14. | |
sharedctypes.py | File | 6245 bytes | December 23 2018 21:37:14. | |
spawn.py | File | 8863 bytes | December 23 2018 21:37:14. | |
synchronize.py | File | 12050 bytes | December 23 2018 21:37:14. | |
util.py | File | 11886 bytes | December 23 2018 21:37:14. |
import os import sys 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._launch(process_obj) def duplicate_for_child(self, fd): return fd def poll(self, flag=os.WNOHANG): if self.returncode is None: while True: try: pid, sts = os.waitpid(self.pid, flag) except OSError as e: # Child process not yet created. See #1731717 # e.errno == errno.ECHILD == 10 return None else: break if pid == self.pid: if os.WIFSIGNALED(sts): self.returncode = -os.WTERMSIG(sts) else: assert os.WIFEXITED(sts) self.returncode = os.WEXITSTATUS(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 terminate(self): if self.returncode is None: try: os.kill(self.pid, signal.SIGTERM) except ProcessLookupError: pass except OSError: if self.wait(timeout=0.1) is None: raise def _launch(self, process_obj): code = 1 parent_r, child_w = os.pipe() self.pid = os.fork() if self.pid == 0: try: os.close(parent_r) if 'random' in sys.modules: import random random.seed() code = process_obj._bootstrap() finally: os._exit(code) else: os.close(child_w) util.Finalize(self, os.close, (parent_r,)) self.sentinel = parent_r
SILENT KILLER Tool