Sep 1, 2022 · Sep 18, 2022 · Sep 18, 2022 · Oct 22, 2022 · Jan 19, 2023 · Feb 10, 2023
diff --git a/Lib/queue.py b/Lib/queue.py
            if immediate:
                self.shutdown_state = _queue_shutdown_immediate
                self.not_empty.notify_all()
                # set self.unfinished_tasks to 0
                # to break the loop in 'self.join()'
                # when quits from `wait()`
                self.unfinished_tasks = 0
                self.all_tasks_done.notify_all()
            else:
                self.shutdown_state = _queue_shutdown
Original file line number	Diff line number	Diff line change
Expand Up		@@ -245,6 +245,10 @@ def shutdown(self, immediate=False):
		if immediate:
		self.shutdown_state = _queue_shutdown_immediate
		self.not_empty.notify_all()
		# set self.unfinished_tasks to 0
		# to break the loop in 'self.join()'
		# when quits from `wait()`
		self.unfinished_tasks = 0
		self.all_tasks_done.notify_all()
		else:
		self.shutdown_state = _queue_shutdown
Expand Down