Merge pull request peterhinch#42 from dbadrian/feature/queue_full_check_optimization

Full check optimization in v3 queue

Author: peterhinch

v3/primitives/queue.py

@@ -48,15 +48,15 @@ def _put(self, val):
         self._queue.append(val)
 
     async def put(self, val):  # Usage: await queue.put(item)
-        if self.qsize() >= self.maxsize and self.maxsize:
+        if self.full():
             # Queue full
             self._evget.clear()
             await self._evget.wait()
             # Task(s) waiting to get from queue, schedule first Task
         self._put(val)
 
     def put_nowait(self, val):  # Put an item into the queue without blocking.
-        if self.maxsize and self.qsize() >= self.maxsize:
+        if self.full():
             raise QueueFull()
         self._put(val)
 
@@ -67,10 +67,6 @@ def empty(self):  # Return True if the queue is empty, False otherwise.
         return len(self._queue) == 0
 
     def full(self):  # Return True if there are maxsize items in the queue.
-        # Note: if the Queue was initialized with maxsize=0 (the default),
-        # then full() is never True.
-
-        if self.maxsize <= 0:
-            return False
-        else:
-            return self.qsize() >= self.maxsize
+        # Note: if the Queue was initialized with maxsize=0 (the default) or
+        # any negative number, then full() is never True.
+        return self.maxsize > 0 and self.qsize() >= self.maxsize