Blockingqueue Inwards Coffee – Arrayblockingqueue Vs Linkedblockingqueue Illustration Plan Tutorial

BlockingQueue inwards Java is added inwards Java 1.5 along amongst diverse other concurrent Utility classes similar ConcurrentHashMap, Counting Semaphore, CopyOnWriteArrrayList etc. BlockingQueue is a unique collection type which non exclusively shop elements precisely too supports catamenia command yesteryear introducing blocking if either BlockingQueue is total or empty. take() method of BlockingQueue volition block if Queue is empty as well as put() method of BlockingQueue volition block if Queue is full. This belongings makes BlockingQueue an ideal alternative for implementing Producer consumer blueprint pattern where ane thread insert chemical gene into BlockingQueue as well as other thread consumes it. In this Java tutorial nosotros volition larn nearly What is BlockingQueue inwards Java, How to piece of job BlockingQueue, ArrayBlockingQueue as well as LinkedBlockingQueue as well as about of import properties of it.

Important properties of BlockingQueue inwards Java

Before using whatever novel Collection degree e.g. BlockingQueue, I e'er read at that spot API documentation to know to a greater extent than nearly it. There are e'er about of import points which is worth remembering as well as avoids potential programming errors spell using novel Collection class. Following listing of points nearly BlockingQueue inwards Java volition help to larn as well as empathise to a greater extent than nearly it.

1) BlockingQueue inwards Java doesn't allow nil elements, diverse implementation of BlockingQueue similar ArrayBlockingQueue, LinkedBlockingQueue throws NullPointerException when yous endeavor to add together nil on queue.

BlockingQueue<String> bQueue = new ArrayBlockingQueue<String>(10);
//bQueue.put(null); //NullPointerException - BlockingQueue inwards Java doesn't allow null
     
bQueue = new LinkedBlockingQueue<String>();
bQueue.put(null);

Exception inwards thread "main" java.lang.NullPointerException
        at java.util.concurrent.LinkedBlockingQueue.put(LinkedBlockingQueue.java:288)

2) BlockingQueue tin travel bounded or unbounded. Influenza A virus subtype H5N1 bounded BlockingQueue is ane which is initialized amongst initial capacity as well as telephone telephone to put() volition travel blocked if BlockingQueue is total as well as size is equal to capacity. This bounding nature makes it ideal to piece of job a shared queue betwixt multiple threads similar inwards most mutual Producer consumer solutions inwards Java. An unbounded Queue is ane which is initialized without capacity, genuinely yesteryear default it initialized amongst Integer.MAX_VALUE. most mutual instance of BlockingQueue uses bounded BlockingQueue every bit shown inwards below example.

BlockingQueue<String> bQueue = new ArrayBlockingQueue<String>(2);
bQueue.put("Java");
System.out.println("Item 1 inserted into BlockingQueue");
bQueue.put("JDK");
System.out.println("Item 2 is inserted on BlockingQueue");
bQueue.put("J2SE");
System.out.println("Done");

Output:
Item 1 inserted into BlockingQueue
Item 2 is inserted on BlockingQueue

This code volition exclusively insert Java as well as JDK into BlockingQueue as well as thus it volition block spell inserting third chemical gene J2SE because size of BlockingQueue is 2 here.

3)BlockingQueue implementations similar ArrayBlockingQueue, LinkedBlockingQueue as well as PriorityBlockingQueue are thread-safe. All queuing method uses concurrency command as well as internal locks to perform performance atomically. Since BlockingQueue too extend Collection, mass Collection operations similar addAll(), containsAll() are non performed atomically until whatever BlockingQueue implementation specifically supports it. So telephone telephone to addAll() may neglect after inserting span of elements.

4) Common methods of BlockingQueue is are put() as well as take() which are blocking methods inwards Java as well as used to insert as well as retrive elements from BlockingQueue inwards Java. put() volition block if BlockingQueue is total as well as take() volition block if BlockingQueue is empty, telephone telephone to take() removes chemical gene from caput of Queue every bit shown inwards next example:

BlockingQueue<String> bQueue = new ArrayBlockingQueue<String>(2);
bQueue.put("Java"); //insert object into BlockingQueue
System.out.println("BlockingQueue after put: " + bQueue);
bQueue.take(); //retrieve object from BlockingQueue inwards Java
System.out.println("BlockingQueue after take: " + bQueue);

Output:
BlockingQueue after put: [Java]
BlockingQueue after take: []

5) BlockingQueue interface extends Collection, Queue as well as Iterable interface which provides it all Collection as well as Queue related methods similar poll(), as well as peak(), different take(), peek() method returns caput of the queue without removing it, poll() too retrieves as well as removes elements from caput precisely tin facial expression till specified fourth dimension if Queue is empty.

BlockingQueue<String> linkedBQueue = new LinkedBlockingQueue<String>(2);
linkedBQueue.put("Java"); //puts object into BlockingQueue
System.out.println("size of BlockingQueue earlier peek : " + linkedBQueue.size());      
System.out.println("example of peek() inwards BlockingQueue: " + linkedBQueue.peek());
System.out.println("size of BlockingQueue after peek : " + linkedBQueue.size());
System.out.println("calling poll() on BlockingQueue: " + linkedBQueue.poll());
System.out.println("size of BlockingQueue after poll : " + linkedBQueue.size());

Output:
size of BlockingQueue earlier peek : 1
instance of peek() inwards BlockingQueue: Java
size of BlockingQueue after peek : 1
calling poll() on BlockingQueue: Java
size of BlockingQueue after poll : 0

6)Other of import methods from BlockingQueue inwards Java is remainingCapacity() as well as offer(), one-time returns disclose remaining infinite inwards BlockingQueue, which tin travel filled without blocking spell afterward insert object into queue if possible as well as render truthful if success as well as imitation if neglect different add() method which throws IllegalStateException if it fails to insert object into BlockingQueue. Use offer() over add() wherever possible.

Usage of BlockingQueue inwards Java

There tin travel many creative usage of BlockingQueue inwards Java given its catamenia command ability. Two of the most mutual ways I run across programmer uses BlockingQueue is to implement Producer Consumer blueprint pattern as well as implementing Bounded buffer inwards Java. It surprisingly made coding as well as inter thread communication over a shared object real easy.

ArrayBlockingQueue as well as LinkedBlockingQueue inwards Java

ArrayBlockingQueue as well as LinkedBlockingQueue are mutual implementation of BlockingQueue<E> interface. ArrayBlockingQueue is backed yesteryear array  and Queue impose orders every bit FIFO. caput of the queue is the oldest chemical gene inwards damage of fourth dimension as well as tail of the queue is youngest element. ArrayBlockingQueue is too fixed size bounded buffer on the other manus LinkedBlockingQueue is an optionally bounded queue built on hap of Linked nodes. In damage of throughput LinkedBlockingQueue provides higher throughput than ArrayBlockingQueue inwards Java.

That’s all on What is BlockingQueue inwards Java as well as How to piece of job it. We receive got seen ii convenient implementation of BlockingQueue i.e. ArrayBlockingQueue as well as LinkedBlockingQueue which comes along amongst Java API. If yous are implementing Producer Consumer blueprint pattern inwards Java, consider using BlockingQueue, it non exclusively brand coding slow precisely too performs amend as well as supply amend robustness as well as stability than writing your ain BlockingQueue or using naked wait as well as notify method.

Further Learning
Java In-Depth: Become a Complete Java Engineer
How to variety ArrayList inwards opposite gild inwards Java

Difference betwixt LinkedList as well as ArrayList inwards Java

10 ways to piece of job Hashtable inwards Java amongst code samples

10 examples of HashSet inwards Java

TreeSet vs HashSet vs LinkedHashSet inwards Java – Interview question