Method put_nowait

Lib/asyncio/queues.py:156–170

Put an item into the queue without blocking. If no free slot is immediately available, raise QueueFull. Raises QueueShutDown if the queue has been shut down.

(self, item)

        return self.put_nowait(item)

    def put_nowait(self, item):
        """Put an item into the queue without blocking.

        If no free slot is immediately available, raise QueueFull.

        Raises QueueShutDown if the queue has been shut down.
        """
        if self._is_shutdown:
            raise QueueShutDown
        if self.full():
            raise QueueFull
        self._put(item)
        self._unfinished_tasks += 1
        self._finished.clear()
        self._wakeup_next(self._getters)

    async def get(self):
        """Remove and return an item from the queue.