/**
 * Fail TootjadTarbijad_Runnable.java
 * @author Jaanus Poial
 * @version 0.5 kevad 99
 */

//======================================================
//  Klassikaline tootja-tarbija u"lesanne 
//  Runnable liidese ning sisemise lo~ime abil tehtud
//======================================================

import java.util.*;

public class TootjadTarbijad_Runnable {
   static final int PUHVRIPIKKUS = 6;
   static Vector yhispuhver = new Vector (PUHVRIPIKKUS);

   public static void main (String[] parameetrid) {
      int tootja1_tiks  = 5000; //millisekundit
      int tootja2_tiks  = 7000; //millisekundit
      int tarbija1_tiks = 3000; //millisekundit
      System.out.println
         ("Puhvri suurus: " + yhispuhver.capacity());
      Tootja  tootja1  =
         new Tootja  (yhispuhver, tootja1_tiks,  "Pro1");
      Tootja  tootja2  =
         new Tootja  (yhispuhver, tootja2_tiks,  "Pro2");
      Tarbija tarbija1 =
         new Tarbija (yhispuhver, tarbija1_tiks, "Con1");
   } // main lopp

} // TootjadTarbijad_Runnable lopp

//=======================================================

class Tootja implements Runnable {
   Vector puhver;
   int tiks;
   String nimi;
   Thread loim;
   // tootja ise ei ole lo~im, ta sisaldab lo~ime

   Tootja (Vector v, int i, String s) {
      puhver = v;
      tiks = i;
      nimi = s;
      loim = new Thread(this); // this on meil Runnable!
      loim.start();  // loomine sisaldab ka ka"ivitamise
   }

   public void run() {
      try {
         while (true) { //lopmatu tsykkel
            tooda();    //iga tiksuga toodab uue asja
            loim.sleep (tiks);
         }
      }
      catch (InterruptedException e) {
      }
   }

   private void tooda()
      throws InterruptedException {
         synchronized (puhver) {
            while (puhver.size() >= puhver.capacity()) {
               puhver.wait(); //puhver on ta"is, oota
            }
            puhver.addElement ("(" + nimi + " > " +
               new Date().toString() + ")"); //ajatempel
            System.out.println (nimi + " > " + 
               puhver.lastElement() +
               " " + tiks + " " + puhver.size());
            puhver.notifyAll();
         } // kriitilise sektsiooni lopp
   }
} // Tootja lopp

//=======================================================

class Tarbija implements Runnable {
   Vector puhver;
   int tiks;
   String nimi;
   Thread loim;

   Tarbija (Vector v, int i, String s) {
      puhver = v;
      tiks = i;
      nimi = s;
      loim = new Thread (this);
      loim.start();
   }

   public void run() {
      try {
         while (true) { //lopmatu tsykkel
            tarbi();    //iga tiksuga tarbib u"he asja
            loim.sleep (tiks);
         }
      }
      catch (InterruptedException e) {
      }
   }

   private void tarbi()
      throws InterruptedException {
         synchronized (puhver) {
            while (puhver.size() <= 0) {
               puhver.wait(); //oota, kuni midagi tekib
            }
            String teade = (String)puhver.firstElement();
            System.out.println (nimi + " < " +
               teade + " " + tiks);
            puhver.removeElementAt (0);
            puhver.notifyAll();
         } // kriitilise sektsiooni lopp
   }
} // Tarbija lopp

//====================
// faili lopp 
//====================