diff options
| author | Benjamin Peterson <benjamin@python.org> | 2008-06-11 02:40:25 (GMT) |
|---|---|---|
| committer | Benjamin Peterson <benjamin@python.org> | 2008-06-11 02:40:25 (GMT) |
| commit | 190d56e00990eadce8ad1b7d1785016cc109db7b (patch) | |
| tree | ef143cf28648baf9fe708640f67586f14273a0ff /Lib/multiprocessing/dummy/connection.py | |
| parent | d5299866f95f1e74255312444176280494d2782a (diff) | |
| download | cpython-190d56e00990eadce8ad1b7d1785016cc109db7b.zip cpython-190d56e00990eadce8ad1b7d1785016cc109db7b.tar.gz cpython-190d56e00990eadce8ad1b7d1785016cc109db7b.tar.bz2 | |
add the multiprocessing package to fulfill PEP 371
Diffstat (limited to 'Lib/multiprocessing/dummy/connection.py')
| -rw-r--r-- | Lib/multiprocessing/dummy/connection.py | 61 |
1 files changed, 61 insertions, 0 deletions
diff --git a/Lib/multiprocessing/dummy/connection.py b/Lib/multiprocessing/dummy/connection.py new file mode 100644 index 0000000..dd2bcb9 --- /dev/null +++ b/Lib/multiprocessing/dummy/connection.py @@ -0,0 +1,61 @@ +#
+# Analogue of `multiprocessing.connection` which uses queues instead of sockets
+#
+# multiprocessing/dummy/connection.py
+#
+# Copyright (c) 2006-2008, R Oudkerk --- see COPYING.txt
+#
+
+__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
+
+ address = property(lambda self: self._backlog_queue)
+
+
+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
+ self._in.not_empty.acquire()
+ self._in.not_empty.wait(timeout)
+ self._in.not_empty.release()
+ return self._in.qsize() > 0
+
+ def close(self):
+ pass
|