multiprocess_manager.py 文件源码

def __init__(self, url, port, authkey=b'abracadabra'):
        class _MyManager(mgr.BaseManager):
            pass
        self._MyManager = _MyManager
        self._server_args = ((url, port), authkey)
        self._server = None
        self._client_connected = False
        self.registry = set()
        # sharing synced objects with special proxies
        self._special_vars = {dtype: {} for dtype in self.SPECIAL_PROXIES}
        ProcessSharing._generate_add_special()