ConcurrentLinkedDeque in Java implements Deque interface and is part of java.util.concurrent package.
ConcurrentLinkedDeque in Java is an unbounded concurrent deque which is thread-safe. It stores its elements as linked nodes where each node stores a reference to both previous and next nodes.
How ConcurrentLinkedDeque differs from the blocking Deque implementations like LinkedBlockingDeque is that ConcurrentLinkedDeque is non-blocking so the operations in this queue don’t block. Since ConcurrentLinkedDeque is non-blocking so the blocking methods like putFirst(), takeFirst() or putLast(), takeLast() which will block if required are not available.
ConcurrentLinkedDeque is similar to its counterpart ConcurrentLinkedQueue, with one difference that it is a double ended queue. It means ConcurrentLinkedDeque allows insertion and removal from both ends. ConcurrentLinkedDeque has methods like addFirst(), addLast(), removeFirst(), removeLast() to facilitate insertion and removal from both ends.
ConcurrentLinkedDeque doesn’t allow null elements
Like most other concurrent collection implementations, this class does not permit the use of null elements.
|
1 2 3 4 5 6 7 8 |
public class ConcurrentLDQ { public static void main(String[] args) { Deque<Integer> conDeque = new ConcurrentLinkedDeque<>(); conDeque.add(10); conDeque.addLast(null); } } |
Output
|
1 2 3 4 5 |
Exception in thread "main" java.lang.NullPointerException at java.base/java.util.Objects.requireNonNull(Objects.java:221) at java.base/java.util.concurrent.ConcurrentLinkedDeque.linkLast(ConcurrentLinkedDeque.java:347) at java.base/java.util.concurrent.ConcurrentLinkedDeque.addLast(ConcurrentLinkedDeque.java:840) at com.knpcode.programs.ConcurrentLDQ.main(ConcurrentLDQ.java:11) |
As you can see trying to add null to the deque results in NullPointerException.
Java ConcurrentLinkedDeque constructors
- ConcurrentLinkedDeque()– Constructs an empty deque.
- ConcurrentLinkedDeque(Collection<? extends E> c)– Constructs a deque initially containing the elements of the given collection, added in traversal order of the collection’s iterator.
ConcurrentLinkedDeque Java example
Here is an example of producer-consumer in Java using ConcurrentLinkedDeque. There is one producer thread and two consumers threads.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 |
public class ConcurrentLDQ { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(4); Deque<Integer> conDeque = new ConcurrentLinkedDeque<>(); // One Producer thread executor.execute(new ConProducer(conDeque)); // Two Consumer thread executor.execute(new ConConsumer(conDeque)); executor.execute(new ConConsumer(conDeque)); executor.shutdown(); } } //Producer class ConProducer implements Runnable{ Deque<Integer> conDeque; ConProducer(Deque<Integer> conDeque){ this.conDeque = conDeque; } @Override public void run() { for(int i = 0; i < 6; i++){ System.out.println("Adding to queue-" + i); conDeque.addFirst(i); } } } //Consumer class ConConsumer implements Runnable{ Deque<Integer> conDeque; ConConsumer(Deque<Integer> conDeque){ this.conDeque = conDeque; } @Override public void run() { for(int i = 0; i < 3; i++){ try { TimeUnit.MILLISECONDS.sleep(10); System.out.println("Thread Name -" + Thread.currentThread().getName() + " Consumer retrieved- " + conDeque.pollLast()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } } |
Output
|
1 2 3 4 5 6 7 8 9 10 11 12 |
Adding to queue-0 Adding to queue-1 Adding to queue-2 Adding to queue-3 Adding to queue-4 Adding to queue-5 Thread Name -pool-1-thread-3 Consumer retrieved- 0 Thread Name -pool-1-thread-2 Consumer retrieved- 1 Thread Name -pool-1-thread-3 Consumer retrieved- 2 Thread Name -pool-1-thread-2 Consumer retrieved- 3 Thread Name -pool-1-thread-3 Consumer retrieved- 4 Thread Name -pool-1-thread-2 Consumer retrieved- 5 |
That’s all for the topic ConcurrentLinkedDeque in Java. If something is missing or you have something to share about the topic please write a comment.
You may also like
- CopyOnWriteArrayList in Java
- ArrayList Vs LinkedList in Java
- Difference Between throw And throws in Java
- final in Java
- Java Program to Check if Armstrong Number
- Java Program to Read a File From HDFS