code: def get_nowait(self):
          
          self._parent._check_closing()
          with self._parent._sync_mutex:
              if self._parent._qsize() == 0:
                  raise AsyncQueueEmpty
  
              item = self._parent._get()
              self._parent._notify_async_not_full(threadsafe=False)
              self._parent._notify_sync_not_full()
              return item
docs: Remove and return an item from the queue.
  
          Return an item if one is immediately available, else raise QueueEmpty.