python
diff --git a/‎Lib/asyncio/queues.py
Copy file name to clipboardExpand all lines: Lib/asyncio/queues.py
+5-2Lines changed: 5 additions & 2 deletions b/‎Lib/asyncio/queues.py
Copy file name to clipboardExpand all lines: Lib/asyncio/queues.py
+5-2Lines changed: 5 additions & 2 deletions
diff --git a/‎Lib/queue.py
Copy file name to clipboardExpand all lines: Lib/queue.py
+4-1Lines changed: 4 additions & 1 deletion b/‎Lib/queue.py
Copy file name to clipboardExpand all lines: Lib/queue.py
+4-1Lines changed: 4 additions & 1 deletion
@@ -261,19 +261,22 @@ def shutdown(self, immediate=False):
         All blocked callers of put() will be unblocked, and also get()
         and join() if 'immediate'. The QueueShutDown exception is raised.
         """
+        if self._shutdown_state is _QueueState.SHUTDOWN_IMMEDIATE:
+            return
+
         if immediate:
             self._shutdown_state = _QueueState.SHUTDOWN_IMMEDIATE
             while self._getters:
                 getter = self._getters.popleft()
                 if not getter.done():
                     getter.set_result(None)
         else:
-            self._shutdown_state =  _QueueState.SHUTDOWN
+            self._shutdown_state = _QueueState.SHUTDOWN
         while self._putters:
             putter = self._putters.popleft()
             if not putter.done():
                 putter.set_result(None)
-        # Release 'joined' tasks/coros
+        # Release 'blocked' tasks/coros via `.join()`
         self._finished.set()
 
 
 
@@ -33,7 +33,7 @@ class ShutDown(Exception):
 class _QueueState(enum.Enum):
     ALIVE = "alive"
     SHUTDOWN = "shutdown"
-    SHUTDOWN_IMMEDIATE = "shutdown_immediate"
+    SHUTDOWN_IMMEDIATE = "shutdown-immediate"
 
 
 class Queue:
@@ -244,6 +244,9 @@ def shutdown(self, immediate=False):
         and join() if 'immediate'. The ShutDown exception is raised.
         '''
         with self.mutex:
+            if self.shutdown_state is _QueueState.SHUTDOWN_IMMEDIATE:
+                return
+
             if immediate:
                 self.shutdown_state = _QueueState.SHUTDOWN_IMMEDIATE
                 self.not_empty.notify_all()