Commit 075c4420 authored by Denis Bilenko's avatar Denis Bilenko

minor changes in comments

parent 8df4f6a2
...@@ -30,7 +30,7 @@ class Queue(object): ...@@ -30,7 +30,7 @@ class Queue(object):
self._event_unlock = None self._event_unlock = None
self._init(maxsize) self._init(maxsize)
# QQQ make maxsize a property whose setter schedules unlock if necessary # QQQ make maxsize into a property with setter that schedules unlock if necessary
def _init(self, maxsize): def _init(self, maxsize):
self.queue = collections.deque() self.queue = collections.deque()
...@@ -216,7 +216,7 @@ class Queue(object): ...@@ -216,7 +216,7 @@ class Queue(object):
def _schedule_unlock(self): def _schedule_unlock(self):
if self._event_unlock is None: if self._event_unlock is None:
self._event_unlock = core.active_event(self._unlock) self._event_unlock = core.active_event(self._unlock)
# QQQ re-active event instead of creating a new one each time # QQQ re-activate event (with event_active libevent call) instead of creating a new one each time
class ItemWaiter(Waiter): class ItemWaiter(Waiter):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment