diff options
| author | Jesse Noller <jnoller@gmail.com> | 2009-11-21 14:06:24 (GMT) |
|---|---|---|
| committer | Jesse Noller <jnoller@gmail.com> | 2009-11-21 14:06:24 (GMT) |
| commit | 7bdd8d946ba3913ad8631f4d7bbc952f16144747 (patch) | |
| tree | 7e32c5170b0c3a27eca8a98155b19046dd333185 /Lib/multiprocessing/queues.py | |
| parent | 6c3767445cf1e595d1729611284216b87f96e088 (diff) | |
| download | cpython-7bdd8d946ba3913ad8631f4d7bbc952f16144747.zip cpython-7bdd8d946ba3913ad8631f4d7bbc952f16144747.tar.gz cpython-7bdd8d946ba3913ad8631f4d7bbc952f16144747.tar.bz2 | |
revert unintended change to multiprocessing/queues.py
Diffstat (limited to 'Lib/multiprocessing/queues.py')
| -rw-r--r-- | Lib/multiprocessing/queues.py | 20 |
1 files changed, 2 insertions, 18 deletions
diff --git a/Lib/multiprocessing/queues.py b/Lib/multiprocessing/queues.py index 67ac49c..ea27991 100644 --- a/Lib/multiprocessing/queues.py +++ b/Lib/multiprocessing/queues.py @@ -47,8 +47,6 @@ class Queue(object): if sys.platform != 'win32': register_after_fork(self, Queue._after_fork) - self.getv = 0 - def __getstate__(self): assert_spawning(self) return (self._maxsize, self._reader, self._writer, @@ -73,8 +71,6 @@ class Queue(object): self._poll = self._reader.poll def put(self, obj, block=True, timeout=None): - if not isinstance(obj, list): - debug('put: %s', obj) assert not self._closed if not self._sem.acquire(block, timeout): raise Full @@ -89,15 +85,11 @@ class Queue(object): self._notempty.release() def get(self, block=True, timeout=None): - self.getv += 1 - debug('self.getv: %s', self.getv) if block and timeout is None: self._rlock.acquire() try: res = self._recv() self._sem.release() - if not isinstance(res, list): - debug('get: %s', res) return res finally: self._rlock.release() @@ -112,8 +104,6 @@ class Queue(object): raise Empty res = self._recv() self._sem.release() - if not isinstance(res, list): - debug('get: %s', res) return res finally: self._rlock.release() @@ -239,22 +229,16 @@ class Queue(object): try: while 1: obj = bpopleft() - if not isinstance(obj, list): - debug('feeder thread got: %s', obj) if obj is sentinel: debug('feeder thread got sentinel -- exiting') close() return + if wacquire is None: - if not isinstance(obj, list): - debug('sending to pipe: %s', obj) send(obj) else: - debug('waiting on wacquire') - wacquire(timeout=30) + wacquire() try: - if not isinstance(obj, list): - debug('sending to pipe: %s', obj) send(obj) finally: wrelease() |