TD1/exo3/Consommateur.java

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