Put the item on the queue. The optional 'block' and 'timeout' arguments are ignored, as this method never blocks. They are provided for compatibility with the Queue class.
(self, item, block=True, timeout=None)
| 270 | self._count = threading.Semaphore(0) |
| 271 | |
| 272 | def put(self, item, block=True, timeout=None): |
| 273 | '''Put the item on the queue. |
| 274 | |
| 275 | The optional 'block' and 'timeout' arguments are ignored, as this method |
| 276 | never blocks. They are provided for compatibility with the Queue class. |
| 277 | ''' |
| 278 | self._queue.append(item) |
| 279 | self._count.release() |
| 280 | |
| 281 | def get(self, block=True, timeout=None): |
| 282 | '''Remove and return an item from the queue. |
no test coverage detected