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         public Producteur(BufferCirc b, String name) {
  15                 buffer = b;
  16                 setThName(name);
  17         }
  18
  19         public void setThName(String name) {
  20                 Thread.currentThread().setName(name);
  21         }
  22
  23         public void run() {
  24                 while (true) {
  25                         buffer.depose(new Integer(val));
  26                         System.out.println (Thread.currentThread().getName() +  " a depose " + val);
  27                         val++;
  28                         try {
  29                                 Thread.sleep(ThreadLocalRandom.current().nextInt(101));
  30                         }
  31                         catch (InterruptedException e) {}
  32                 }
  33         }
  34
  35 } // fin classe Producteur