How to interrupt a BlockingQueue which is blocking on take()?

by

If interrupting the thread is not an option, another is to place a “marker” or “command” object on the queue that would be recognized as such by MyObjHandler and break out of the loop.

More Related Contents:

  1. Why must wait() always be in synchronized block
  2. How to share data with two(2) SwingWorker class in Java
  3. ConcurrentModificationException despite using synchronized
  4. Volatile vs Static in Java
  5. How to make ThreadPoolExecutor’s submit() method block if it is saturated?
  6. When would you call java’s thread.run() instead of thread.start()?
  7. Convert from List to CompletableFuture
  8. Why there is no ConcurrentHashSet against ConcurrentHashMap
  9. How to get the ThreadPoolExecutor to increase threads to max before queueing?
  10. How do I call some blocking method with a timeout in Java?
  11. Java Executors: how can I set task priority?
  12. What are the main uses of yield(), and how does it differ from join() and interrupt()?
  13. Volatile variable in Java
  14. What is the difference between synchronized on lockObject and using this as the lock?
  15. When should I use a CompletionService over an ExecutorService?
  16. Are non-synchronised static methods thread safe if they don’t modify static class variables?
  17. When do I need to use AtomicBoolean in Java?
  18. Java ExecutorService: awaitTermination of all recursively created tasks
  19. Hashmap concurrency issue
  20. Which concurrent Queue implementation should I use in Java?
  21. Why should I use concurrent characteristic in parallel stream with collect?
  22. Java concurrency: is final field (initialized in constructor) thread-safe?
  23. Java: ExecutorService that blocks on submission after a certain queue size [duplicate]
  24. Jboss Java EE container and an ExecutorService
  25. Java: is there no AtomicFloat or AtomicDouble?
  26. How to pause/resume all threads in an ExecutorService in Java?
  27. Multithreading Socket communication Client/Server
  28. Not thread-safe Object publishing
  29. notifyAll() throws IllegalMonitorStateException
  30. Will a chain of method calls (CompletableFuture API) execute asynchronously if the first method in a chain is asynchronous?

Leave a Comment