How To Role Wait, Notify As Well As Notifyall Inward Coffee - Producer Consumer Example

You tin purpose wait, notify in addition to notifyAll methods to communicate betwixt threads inward Java. For example, if yous direct hold 2 threads running inward your programme e.g.Producer in addition to Consumer in addition to hence producer thread tin communicate to the consumer that it tin start consuming at i time because at that spot are items to eat inward the queue. Similarly, a consumer thread tin say the producer that it tin too start putting items at i time because at that spot is around infinite inward the queue, which is created equally a effect of consumption. Influenza A virus subtype H5N1 thread tin purpose wait() method to intermission in addition to attain nil depending upon around condition. For example, inward the producer-consumer problem, producer thread should human face if the queue is total in addition to consumer thread should human face if the queue is empty.

If around thread is waiting for around status to top true, yous tin purpose notify in addition to notifyAll methods to inform them that status is at i time changed in addition to they tin wake up.

Both notify() in addition to notifyAll() method sends a notification but notify sends the notification to alone i of the waiting thread, no guarantee which thread volition have notification in addition to notifyAll() sends the notification to all threads.

So if alone i thread is waiting for an object lock, too known equally a monitor in addition to hence both notify in addition to notifyAll volition post the notification to it. If multiple threads are waiting on a monitor in addition to hence notify volition alone inform i of the lucky thread in addition to residual volition non have whatever notification, but notifyAll volition inform all threads.

In this Java multi-threading tutorial yous volition larn how to purpose wait, notify in addition to notifyAll() method inward Java to implement inter-thread communication yesteryear solving the producer-consumer problem.

BTW, if yous are serious virtually mastering concurrency in addition to multi-threading, I strongly advise yous to read Java Concurrency inward Practice yesteryear Brian Goetz, without reading that majority your journeying to Java multi-threading is non complete. It's in all probability i of the most recommended books to Java developers.

How to purpose human face in addition to notify inward code

Even though human face in addition to notify are quite a key concept in addition to they are defined inward the object class, surprisingly, it's non slowly to write code using human face in addition to notify. You tin evidence this during an interview yesteryear bespeak the candidate to write code to solve producer consumer occupation using human face in addition to notify yesteryear hand.

I am certain many volition travel stuck in addition to brand mistakes e.g. synchronizing at the incorrect place, non calling human face on a correct object or non next criterion idiom. To travel honest its confusing for non-regular coders.

First confusion arise from the fact, how to telephone outcry upwardly wait() method? Since wait method is non defined inward Thread class, yous cannot exactly telephone outcry upwardly Thread.wait(), that won't operate but since many Java developers are used to calling Thread.sleep() they endeavour the same matter alongside wait() method in addition to stuck.

You demand to telephone outcry upwardly wait() method on the object which is shared betwixt 2 threads, inward producer-consumer occupation its the queue which is shared betwixt producer in addition to consumer threads.

The minute confusion comes from the fact that human face needs to travel a telephone outcry upwardly from synchronized block or method? So if yous purpose synchronized block, which object should travel position to top within the block? This should travel the same object, whose lock yous desire to acquire i.e. the shared object betwixt multiple threads. In our representative it's queue.

Always telephone outcry upwardly human face in addition to notify from Loop Instead of If Block

Once yous know that yous demand to telephone outcry upwardly human face from synchronized context in addition to on the shared object, side yesteryear side matter is to avoid fault made yesteryear several Java developer yesteryear calling wait() method within if block instead of while loop.

Since yous telephone outcry upwardly human face within a conditional block e.g. producer thread should telephone outcry upwardly wait() if queue is full, start instinct goes towards using if block, but calling wait() within if block tin atomic number 82 to subtle bugs because it's possible for thread to wake upwardly spuriously fifty-fifty when waiting status is non changed.

If yous don't banking enterprise fit the status i time again later waking upwardly yesteryear using a loop, yous volition accept the incorrect activity which may drive occupation e.g. trying to insert special on a total queue or trying to eat from an empty queue. That's why yous should ever telephone outcry upwardly human face in addition to notify method from a loop in addition to non from if block.

I too advise reading Effective Java special on the same topic, in all probability the best reference inward how to properly telephone outcry upwardly human face in addition to notify method.

Based upon to a higher house noesis hither is  the criterion code template or idiom to telephone outcry upwardly human face in addition to notify method inward Java :

// The criterion idiom for calling the wait method inward Java synchronized (sharedObject) {    while (condition) {       sharedObject.wait(); // (Releases lock, in addition to reacquires on wakeup)    }    ... // do activity based upon status e.g. accept or position into queue }

As I suggested, yous should ever invoke human face method from a loop. The loop is used to evidence the status earlier in addition to later waiting. If the status nonetheless holds in addition to the notify (or notifyAll) method has already been invoked earlier a thread calls wait() method, in addition to hence at that spot is no guarantee that the thread volition ever awake from the wait, potentially causing a deadlock.

Java wait(), notify() in addition to notifyAll() Example

Here is our sample programme to demonstrate how to purpose human face in addition to notify method inward Java. In this program, nosotros direct hold used the criterion idiom discussed to a higher house to telephone outcry upwardly wait(), notify() in addition to notifyAll() method inward Java.

In this program, nosotros direct hold 2 threads named PRODUCER in addition to CONSUMER in addition to implemented using Producer in addition to Consumer shape which extends Thread class. The logic of what producer in addition to the consumer should attain is written inward their respective run() method.

Main thread starts both producer in addition to consumer threads in addition to too create an object of LinkedList shape to portion equally Queue betwixt them. If yous don't know LinkedList too implements Queue interface inward Java.

Producer runs inward an infinite loop in addition to keeps inserting random integer value into Queue until the queue is full. We banking enterprise fit this status at while(queue.size == maxSize), call back earlier doing this banking enterprise fit nosotros synchronize on queue object hence that no other thread modify the queue when nosotros are doing this check.

If Queue is total in addition to hence our PRODUCER thread waits until CONSUMER thread eat i special in addition to brand infinite inward your queue in addition to telephone outcry upwardly notify() method to inform PRODUCER thread. Both wait() in addition to notify() method are called on shared object which is queue inward our case.

import java.util.LinkedList; import java.util.Queue; import java.util.Random;  /**  * Simple Java programme to demonstrate How to purpose wait, notify in addition to notifyAll()  * method inward Java yesteryear solving producer consumer problem.  *   * @author Javin Paul  */ public class ProducerConsumerInJava {      public static void main(String args[]) {         System.out.println("How to purpose human face in addition to notify method inward Java");         System.out.println("Solving Producer Consumper Problem");                  Queue<Integer> buffer = new LinkedList<>();         int maxSize = 10;                  Thread producer = new Producer(buffer, maxSize, "PRODUCER");         Thread consumer = new Consumer(buffer, maxSize, "CONSUMER");                  producer.start();         consumer.start();               }  }  /**  * Producer Thread volition maintain producing values for Consumer  * to consumer. It volition purpose wait() method when Queue is total  * in addition to purpose notify() method to post notification to Consumer  * Thread.  *   * @author WINDOWS 8  *  */ class Producer extends Thread {     private Queue<Integer> queue;     private int maxSize;          public Producer(Queue<Integer> queue, int maxSize, String name){         super(name);         this.queue = queue;         this.maxSize = maxSize;     }          @Override     public void run() {         while (true) {             synchronized (queue) {                 while (queue.size() == maxSize) {                     try {                         System.out .println("Queue is full, "                                 + "Producer thread waiting for "                                 + "consumer to accept something from queue");                         queue.wait();                     } catch (Exception ex) {                         ex.printStackTrace();                     }                 }                  Random random = new Random();                 int i = random.nextInt();                 System.out.println("Producing value : " + i);                 queue.add(i);                 queue.notifyAll();             }          }     } }  /**  * Consumer Thread volition consumer values shape shared queue.  * It volition too purpose wait() method to human face if queue is  * empty. It volition too purpose notify method to post   * notification to producer thread later consuming values  * from queue.  *   * @author WINDOWS 8  *  */ class Consumer extends Thread {     private Queue<Integer> queue;     private int maxSize;          public Consumer(Queue<Integer> queue, int maxSize, String name){         super(name);         this.queue = queue;         this.maxSize = maxSize;     }          @Override     public void run() {         while (true) {             synchronized (queue) {                 while (queue.isEmpty()) {                     System.out.println("Queue is empty,"                             + "Consumer thread is waiting"                             + " for producer thread to position something inward queue");                     try {                         queue.wait();                     } catch (Exception ex) {                         ex.printStackTrace();                     }                  }                 System.out.println("Consuming value : " + queue.remove());                 queue.notifyAll();             }          }     } }  Output How to purpose human face in addition to notify method inward Java Solving Producer Consumper Problem Queue is empty,Consumer thread is waiting for producer thread to position something inward queue Producing value : -1692411980 Producing value : 285310787 Producing value : -1045894970 Producing value : 2140997307 Producing value : 1379699468 Producing value : 912077154 Producing value : -1635438928 Producing value : -500696499 Producing value : -1985700664 Producing value : 961945684 Queue is full, Producer thread waiting for consumer to accept something from queue Consuming value : -1692411980 Consuming value : 285310787 Consuming value : -1045894970 Consuming value : 2140997307 Consuming value : 1379699468 Consuming value : 912077154 Consuming value : -1635438928 Consuming value : -500696499 Consuming value : -1985700664 Consuming value : 961945684 Queue is empty,Consumer thread is waiting for producer thread to position something inward queue Producing value : 1182138498

In social club to sympathise this programme better, I advise yous debug it instead of running. Once yous start your programme inward debug agency it volition halt at either PRODUCER or CONSUMER thread, depending upon which i thread scheduler chose to give CPU.

Since both threads direct hold human face status they volition top there, at i time yous exactly run it in addition to come across what it does, it volition most probable impress the output shown above. You tin fifty-fifty use Step Into in addition to Step Over buttons inward Eclipse to run the programme measurement yesteryear measurement to sympathise it better.

Things to Remember virtually Using wait(), notify() in addition to notifyAll() method 

1. You tin purpose wait() in addition to notify() method to implement inter-thread communication inward Java. Not exactly i or 2 threads but multiple threads tin communicate to each other yesteryear using these methods.
2. Always telephone outcry upwardly wait(), notify() in addition to notifyAll() methods from synchronized method or synchronized block otherwise JVM volition throw IllegalMonitorStateException.
3. Always telephone outcry upwardly human face in addition to notify method from a loop in addition to never from if() block, because loop evidence waiting status earlier in addition to later sleeping in addition to handles notification fifty-fifty if waiting for the status is non changed.
4. Always telephone outcry upwardly human face inward shared object e.g. shared queue inward this example.
5. Prefer notifyAll() over notify() method due to reasons given inward this article. 

That's all virtually how to purpose wait, notify in addition to notifyAll() method inward Java. You should purpose human face in addition to notify for inter-thread communication inward Java alone if yous know what yous are doing otherwise at that spot are many high-level concurrency utilities available for the unlike task.

For example, if yous desire to implement producer-consumer blueprint in addition to hence yous tin purpose BlockingQueue which volition create out both thread-safety in addition to menstruum command for yous if yous desire your thread should human face for other threads earlier proceeding yous tin purpose CycliBarrier or CountDownLatch or if yous desire to protect resources yous tin purpose Semaphore.

Further Learning
Multithreading in addition to Parallel Computing inward Java
Java Concurrency inward Practice - The Book
Applying Concurrency in addition to Multi-threading to Common Java Patterns
Java Concurrency inward Practice Course yesteryear Heinz Kabutz

Share this post