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/managers.py (1836B)

import multiprocessing as mp
from multiprocessing.managers import SyncManager, State
from .process import LokyProcess as Process

class LokyManager(SyncManager):
    def start(self, initializer=None, initargs=()):
        '''Spawn a server process for this manager object'''
        assert self._state.value == State.INITIAL

if (initializer is not None
                and not hasattr(initializer, '__call__')):
            raise TypeError('initializer must be a callable')

# pipe over which we will retrieve address of server
        reader, writer = mp.Pipe(duplex=False)

# spawn process which runs a server
        self._process = Process(
            target=type(self)._run_server,
            args=(self._registry, self._address, bytes(self._authkey),
                  self._serializer, writer, initializer, initargs),
        )
        ident = ':'.join(str(i) for i in self._process._identity)
        self._process.name = type(self).__name__ + '-' + ident
        self._process.start()

# get address of server
        writer.close()
        self._address = reader.recv()
        reader.close()

# register a finalizer
        self._state.value = State.STARTED
        self.shutdown = mp.util.Finalize(
            self, type(self)._finalize_manager,
            args=(self._process, self._address, self._authkey,
                  self._state, self._Client),
            exitpriority=0
        )

############################################################################### # compat for UNIX 2.7 and 3.3 # Manager with LokyContext server. # This avoids having a Manager using fork and breaks the fd. # # author: Thomas Moreau and Olivier Grisel # # based on multiprocessing/managers.py (17/02/2017) # * Overload the start method to use LokyContext and launch a loky subprocess # import multiprocessing as mp from multiprocessing.managers import SyncManager, State from .process import LokyProcess as Process class LokyManager(SyncManager): def start(self, initializer=None, initargs=()): '''Spawn a server process for this manager object''' assert self._state.value == State.INITIAL if (initializer is not None and not hasattr(initializer, '__call__')): raise TypeError('initializer must be a callable') # pipe over which we will retrieve address of server reader, writer = mp.Pipe(duplex=False) # spawn process which runs a server self._process = Process( target=type(self)._run_server, args=(self._registry, self._address, bytes(self._authkey), self._serializer, writer, initializer, initargs), ) ident = ':'.join(str(i) for i in self._process._identity) self._process.name = type(self).__name__ + '-' + ident self._process.start() # get address of server writer.close() self._address = reader.recv() reader.close() # register a finalizer self._state.value = State.STARTED self.shutdown = mp.util.Finalize( self, type(self)._finalize_manager, args=(self._process, self._address, self._authkey, self._state, self._Client), exitpriority=0 )