TD1/exo3/Consommateur.java

   1
   2
   3 public class Consommateur implements Runnable {
   4
   5         private BufferCirc buffer;
   6
   7
   8         public Consommateur(BufferCirc b) {
   9                 buffer = b;
  10         }
  11
  12
  13         public void run() {
  14                 Integer val;
  15                 while (true) {
  16                         val = (Integer)buffer.preleve();
  17                         System.out.println (Thread.currentThread().getName() + " a preleve " + val);
  18                         try {
  19                                 Thread.sleep((int)(Math.random()*1000));
  20                         }
  21                         catch (InterruptedException e) {}
  22                 }
  23         }
  24
  25 } // fin classe Consommateur