Remove and return an item from the queue. Return an item if one is immediately available, else raise QueueEmpty. Raises QueueShutDown if the queue has been shut down and is empty, or if the queue has been shut down immediately.
(self)
| 201 | return self.get_nowait() |
| 202 | |
| 203 | def get_nowait(self): |
| 204 | """Remove and return an item from the queue. |
| 205 | |
| 206 | Return an item if one is immediately available, else raise QueueEmpty. |
| 207 | |
| 208 | Raises QueueShutDown if the queue has been shut down and is empty, or |
| 209 | if the queue has been shut down immediately. |
| 210 | """ |
| 211 | if self.empty(): |
| 212 | if self._is_shutdown: |
| 213 | raise QueueShutDown |
| 214 | raise QueueEmpty |
| 215 | item = self._get() |
| 216 | self._wakeup_next(self._putters) |
| 217 | return item |
| 218 | |
| 219 | def task_done(self): |
| 220 | """Indicate that a formerly enqueued task is complete. |