(self)
| 323 | # This allows the C version to use a different implementation. |
| 324 | |
| 325 | def __init__(self): |
| 326 | self._queue = deque() |
| 327 | self._count = threading.Semaphore(0) |
| 328 | |
| 329 | def put(self, item, block=True, timeout=None): |
| 330 | '''Put the item on the queue. |