Skip to content
1 change: 1 addition & 0 deletions Lib/queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,6 +253,7 @@ def shutdown(self, immediate=False):
# release all blocked threads in `join()`
self.all_tasks_done.notify_all()
self.not_empty.notify_all()
# All getters need to re-check queue-empty to raise ShutDown
self.not_full.notify_all()

# Override these methods to implement other queue organizations
Expand Down