Current Path: > > lib64 > python3.6 > multiprocessing
Operation : Linux premium107.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 : 198.54.126.246 | Your IP: 216.73.216.181 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 | February 05 2026 20:00:12. | |
| 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