csp2: CSP2/CSP2_env/env-d9b9114564458d9d-741b3de822f2aaca6c6caa4325c4afce/lib/python3.8/multiprocessing/dummy/connection.py comparison

planemo upload commit 2e9511a184a1ca667c7be0c6321a36dc4e3d116d

comparison

equal deleted inserted replaced

-:0e9998148a16
+:33d812a61356
+#
+# Analogue of `multiprocessing.connection` which uses queues instead of sockets
+#
+# multiprocessing/dummy/connection.py
+#
+# Copyright (c) 2006-2008, R Oudkerk
+# Licensed to PSF under a Contributor Agreement.
+#
+__all__ = [ 'Client', 'Listener', 'Pipe' ]
+from queue import Queue
+families = [None]
+class Listener(object):
+def __init__(self, address=None, family=None, backlog=1):
+self._backlog_queue = Queue(backlog)
+def accept(self):
+return Connection(*self._backlog_queue.get())
+def close(self):
+self._backlog_queue = None
+@property
+def address(self):
+return self._backlog_queue
+def __enter__(self):
+return self
+def __exit__(self, exc_type, exc_value, exc_tb):
+self.close()
+def Client(address):
+_in, _out = Queue(), Queue()
+address.put((_out, _in))
+return Connection(_in, _out)
+def Pipe(duplex=True):
+a, b = Queue(), Queue()
+return Connection(a, b), Connection(b, a)
+class Connection(object):
+def __init__(self, _in, _out):
+self._out = _out
+self._in = _in
+self.send = self.send_bytes = _out.put
+self.recv = self.recv_bytes = _in.get
+def poll(self, timeout=0.0):
+if self._in.qsize() > 0:
+return True
+if timeout <= 0.0:
+return False
+with self._in.not_empty:
+self._in.not_empty.wait(timeout)
+return self._in.qsize() > 0
+def close(self):
+pass
+def __enter__(self):
+return self
+def __exit__(self, exc_type, exc_value, exc_tb):
+self.close()

Mercurial > repos > rliterman > csp2