diff options
| author | Jakub Stasiak <jakub@stasiak.at> | 2014-11-11 23:36:45 +0000 |
|---|---|---|
| committer | Jakub Stasiak <jakub@stasiak.at> | 2014-11-11 23:37:09 +0000 |
| commit | 019ce17945cd3fac621726fbef7abff93b0c3ef9 (patch) | |
| tree | 8f2a0118156cab86417b95eb00d4a39124931777 /eventlet/queue.py | |
| parent | 272db8b4025662c5314ea1660c0ed2fe2ebe4499 (diff) | |
| download | eventlet-019ce17945cd3fac621726fbef7abff93b0c3ef9.tar.gz | |
Improve PEP8 conformance
Diffstat (limited to 'eventlet/queue.py')
| -rw-r--r-- | eventlet/queue.py | 18 |
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 |
