TD1/exo3/Producteur.java

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