source: liacs/cvp/java/BEER_DRINKERS/Beer_Drinkers.java@ 313

/*

Juan Guillen Scholten.
Leiden University.

An example of monitor use in Java.

There are N drinkers drinking beer in a pub. After a while some of them want to 
go to the toilet, unfortunately there is just one available. So only 
one drinker can enjoy the toilet at the same time and the rest must wait.

*/

//
// The monitor class.
//
class Toilet 
{
  private boolean occupied = false; 
   
  Toilet () {};  // constructor
  
  //
  // Try to enter the toilet. If occupied then 
  // drinker has to wait, else drinker can enter.
  //
  synchronized void try_to_enter ()
  {
     while (occupied)
     {
        try { wait(); } catch (InterruptedException e) 
        {
           //
           // In Java you always have to catch an exception 
           // when doing a wait. 
           //
           System.out.println("interruptedException caught");
        }
     }
     occupied = true;
  }// try_to_enter 
  
  //
  // Leave the toilet. Do a notify for if somebody else 
  // is waiting. 
  // 
  synchronized void leave_toilet ()
  {
     occupied = false;
     notify();         // same as signal
  }// leave_toilet  
}// Toilet 

class Drinker extends Thread
{
   int id;
   private Toilet toilet;
   
   Drinker (int number, Toilet a)
   {
      super ("Drinker"+number);
      this.id = number;
      toilet = a;
   }// constructor 

   public void run ()
   {
      int times;
      int index = 0;
      int sleeptime;

      times = (int) (Math.random () * 20); // number of times 
                                           // going to the toilet
      while ( index < times )
      {
         //
         // Drinking beer.
         //
         sleeptime = (int) (Math.random () * 2000); // 2000 = 2 sec. 
         try {sleep (sleeptime);} catch (Exception e) {}
         
         //
         // Trying to enter the toilet.
         //
         System.out.println("Drinker "+ id +" wants to go to the toilet.");
         toilet.try_to_enter();
         
         //
         // Using the toilet.
         // 
         System.out.println("Drinker "+ id +" enters the toilet.");
         sleeptime = (int) (Math.random () * 2000); 
         try {sleep (sleeptime);} catch (Exception e) {}
         
         //
         // Leaving the toilet.
         // 
         System.out.println("Drinker "+ id +" leaves the toilet and says: NEXT!");
         System.out.println(" ");
         toilet.leave_toilet();
         index++;
         
      }
      System.out.println("Drinker "+ id + " goes home.");
      System.out.println(" ");
   }// run
}// Drinker 

public class Beer_Drinkers
{
   public static void main (String args[])
   {
      Toilet toilet;
      int N = 4;            // number of drinkers
      int i;
      System.out.println("Amount of drinkers : "+ N + ".");
      System.out.println(" ");
      toilet = new Toilet();
      Drinker [] drinker = new Drinker [N];
      
      //
      // Creating the drinkers.
      //
      for (i = 0; i < N; i++)
      {
         drinker[i] = new Drinker (i, toilet);
      }
     
      //
      // Starting the drinkers.
      //
      for (i = 0; i < N; i++)
      {
         drinker[i].start();
      } 
      
    }// main 
}// Beer_Drinkers