FM / backend

/usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend/

/usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
compat.py	995	0644	edit dl rm
compat_posix.py	334	0644	edit dl rm
compat_win32.py	1407	0644	edit dl rm
context.py	13847	0644	edit dl rm
fork_exec.py	1372	0644	edit dl rm
managers.py	1836	0644	edit dl rm
popen_loky_posix.py	7113	0644	edit dl rm
popen_loky_win32.py	5724	0644	edit dl rm
process.py	3526	0644	edit dl rm
queues.py	8990	0644	edit dl rm
reduction.py	9663	0644	edit dl rm
resource_tracker.py	14821	0644	edit dl rm
semlock.py	8918	0644	edit dl rm
spawn.py	9207	0644	edit dl rm
synchronize.py	11662	0644	edit dl rm
utils.py	5691	0644	edit dl rm
_posix_reduction.py	2223	0644	edit dl rm
_posix_wait.py	3319	0644	edit dl rm
_win_reduction.py	3724	0644	edit dl rm
_win_wait.py	1956	0644	edit dl rm
__init__.py	398	0644	edit dl rm

Edit: /usr/local/lib/python3.6/site-packages/joblib/externals/loky/backend/_win_wait.py (1956B)

import ctypes
import sys
from time import sleep

if sys.platform == 'win32' and sys.version_info[:2] < (3, 3):
    from _subprocess import WaitForSingleObject, WAIT_OBJECT_0

try:
        from time import monotonic
    except ImportError:
        # Backward old for crappy old Python that did not have cross-platform
        # monotonic clock by default.

# TODO: do we want to add support for cygwin at some point? See:
        # https://github.com/atdt/monotonic/blob/master/monotonic.py
        GetTickCount64 = ctypes.windll.kernel32.GetTickCount64
        GetTickCount64.restype = ctypes.c_ulonglong

def monotonic():
            """Monotonic clock, cannot go backward."""
            return GetTickCount64() / 1000.0

def wait(handles, timeout=None):
        """Backward compat for python2.7

This function wait for either:
        * one connection is ready for read,
        * one process handle has exited or got killed,
        * timeout is reached. Note that this function has a precision of 2
          msec.
        """
        if timeout is not None:
            deadline = monotonic() + timeout

while True:
            # We cannot use select as in windows it only support sockets
            ready = []
            for h in handles:
                if type(h) in [int, long]:
                    if WaitForSingleObject(h, 0) == WAIT_OBJECT_0:
                        ready += [h]
                elif h.poll(0):
                    ready.append(h)
            if len(ready) > 0:
                return ready
            sleep(.001)
            if timeout is not None and deadline - monotonic() <= 0:
                return []

############################################################################### # Compat for wait function on Windows system # # author: Thomas Moreau and Olivier Grisel # # adapted from multiprocessing/connection.py (17/02/2017) # * Backport wait function to python2.7 # import ctypes import sys from time import sleep if sys.platform == 'win32' and sys.version_info[:2] < (3, 3): from _subprocess import WaitForSingleObject, WAIT_OBJECT_0 try: from time import monotonic except ImportError: # Backward old for crappy old Python that did not have cross-platform # monotonic clock by default. # TODO: do we want to add support for cygwin at some point? See: # https://github.com/atdt/monotonic/blob/master/monotonic.py GetTickCount64 = ctypes.windll.kernel32.GetTickCount64 GetTickCount64.restype = ctypes.c_ulonglong def monotonic(): """Monotonic clock, cannot go backward.""" return GetTickCount64() / 1000.0 def wait(handles, timeout=None): """Backward compat for python2.7 This function wait for either: * one connection is ready for read, * one process handle has exited or got killed, * timeout is reached. Note that this function has a precision of 2 msec. """ if timeout is not None: deadline = monotonic() + timeout while True: # We cannot use select as in windows it only support sockets ready = [] for h in handles: if type(h) in [int, long]: if WaitForSingleObject(h, 0) == WAIT_OBJECT_0: ready += [h] elif h.poll(0): ready.append(h) if len(ready) > 0: return ready sleep(.001) if timeout is not None and deadline - monotonic() <= 0: return []