summaryrefslogtreecommitdiff
path: root/eventlet/queue.py
diff options
context:
space:
mode:
authorJakub Stasiak <jakub@stasiak.at>2014-11-11 23:36:45 +0000
committerJakub Stasiak <jakub@stasiak.at>2014-11-11 23:37:09 +0000
commit019ce17945cd3fac621726fbef7abff93b0c3ef9 (patch)
tree8f2a0118156cab86417b95eb00d4a39124931777 /eventlet/queue.py
parent272db8b4025662c5314ea1660c0ed2fe2ebe4499 (diff)
downloadeventlet-019ce17945cd3fac621726fbef7abff93b0c3ef9.tar.gz
Improve PEP8 conformance
Diffstat (limited to 'eventlet/queue.py')
-rw-r--r--eventlet/queue.py18
1 files changed, 12 insertions, 6 deletions
diff --git a/eventlet/queue.py b/eventlet/queue.py
index b9e660a..5a82238 100644
--- a/eventlet/queue.py
+++ b/eventlet/queue.py
@@ -82,7 +82,9 @@ class Waiter(object):
waiting = ' waiting'
else:
waiting = ''
- return '<%s at %s%s greenlet=%r>' % (type(self).__name__, hex(id(self)), waiting, self.greenlet)
+ return '<%s at %s%s greenlet=%r>' % (
+ type(self).__name__, hex(id(self)), waiting, self.greenlet,
+ )
def __str__(self):
"""
@@ -195,7 +197,8 @@ class LightQueue(object):
"""Resizes the queue's maximum size.
If the size is increased, and there are putters waiting, they may be woken up."""
- if self.maxsize is not None and (size is None or size > self.maxsize): # None is not comparable in 3.x
+ # None is not comparable in 3.x
+ if self.maxsize is not None and (size is None or size > self.maxsize):
# Maybe wake some stuff up
self._schedule_unlock()
self.maxsize = size
@@ -219,7 +222,8 @@ class LightQueue(object):
``Queue(None)`` is never full.
"""
- return self.maxsize is not None and self.qsize() >= self.maxsize # None is not comparable in 3.x
+ # None is not comparable in 3.x
+ return self.maxsize is not None and self.qsize() >= self.maxsize
def put(self, item, block=True, timeout=None):
"""Put an item into the queue.
@@ -345,7 +349,9 @@ class LightQueue(object):
putter.switch(putter)
else:
self.putters.add(putter)
- elif self.putters and (self.getters or self.maxsize is None or self.qsize() < self.maxsize):
+ elif self.putters and (self.getters or
+ self.maxsize is None or
+ self.qsize() < self.maxsize):
putter = self.putters.pop()
putter.switch(putter)
else:
@@ -404,8 +410,8 @@ class Queue(LightQueue):
def task_done(self):
'''Indicate that a formerly enqueued task is complete. Used by queue consumer threads.
- For each :meth:`get <Queue.get>` used to fetch a task, a subsequent call to :meth:`task_done` tells the queue
- that the processing on the task is complete.
+ For each :meth:`get <Queue.get>` used to fetch a task, a subsequent call to
+ :meth:`task_done` tells the queue that the processing on the task is complete.
If a :meth:`join` is currently blocking, it will resume when all items have been processed
(meaning that a :meth:`task_done` call was received for every item that had been