https://kodejava.org/how-do-i-close-or-shutdown-a-blockingqueue/
How do I close or shutdown a BlockingQueue?