LinkedBlockingQueue vs ConcurrentLinkedQueue

by

For a producer/consumer thread, I’m not sure that ConcurrentLinkedQueue is even a reasonable option – it doesn’t implement BlockingQueue, which is the fundamental interface for producer/consumer queues IMO. You’d have to call poll(), wait a bit if you hadn’t found anything, and then poll again etc… leading to delays when a new item comes in, and inefficiencies when it’s empty (due to waking up unnecessarily from sleeps).

From the docs for BlockingQueue:

BlockingQueue implementations are designed to be used primarily for producer-consumer queues

I know it doesn’t strictly say that only blocking queues should be used for producer-consumer queues, but even so…

More Related Contents:

  1. Which concurrent Queue implementation should I use in Java?
  2. How to wait for all threads to finish, using ExecutorService?
  3. Is there an advantage to use a Synchronized Method instead of a Synchronized Block?
  4. Why is creating a Thread said to be expensive?
  5. When and how should I use a ThreadLocal variable?
  6. What is the difference between Thread.start() and Thread.run()?
  7. Synchronization vs Lock
  8. Java Wait and Notify: IllegalMonitorStateException
  9. Are static variables shared between threads?
  10. How do synchronized static methods work in Java and can I use it for loading Hibernate entities?
  11. Is iterating ConcurrentHashMap values thread safe?
  12. Why use a ReentrantLock if one can use synchronized(this)?
  13. Is it safe to get values from a java.util.HashMap from multiple threads (no modification)?
  14. How do I implement task prioritization using an ExecutorService in Java 5?
  15. Constructor synchronization in Java
  16. More efficient way for pausing loop wanted
  17. How can CopyOnWriteArrayList be thread-safe?
  18. Javafx: Difference between javafx.concurent and Platform.runLater?
  19. Instruction reordering & happens-before relationship [duplicate]
  20. When should we use Java’s Thread over Executor?
  21. Run Java Threads sequentially
  22. Why should I use concurrent characteristic in parallel stream with collect?
  23. ThreadPoolExecutor Block When its Queue Is Full?
  24. Why doesn’t volatile in java 5+ ensure visibility from another thread?
  25. Concurrent JUnit testing
  26. How to pause/resume all threads in an ExecutorService in Java?
  27. Handling Exceptions for ThreadPoolExecutor
  28. Multithreading Socket communication Client/Server
  29. Does a breakpoint halt all threads?
  30. Are 64 bit assignments in Java atomic on a 32 bit machine?

Leave a Comment