X-Git-Url: https://git.piment-noir.org/?p=TD_SR.git;a=blobdiff_plain;f=TD1%2Fexo3%2FConsommateur.java;h=06dd95db9dc89f2f1f46911bca0503b515c7d6ab;hp=28a5efa78427e74ebc6f5aab516fc4f4a3b115fd;hb=ce28a0211974450cf5df46e2065fb39350e029ec;hpb=d3ae3c42030dcfc0d1de38673f221c7618863ca9 diff --git a/TD1/exo3/Consommateur.java b/TD1/exo3/Consommateur.java index 28a5efa..06dd95d 100644 --- a/TD1/exo3/Consommateur.java +++ b/TD1/exo3/Consommateur.java @@ -1,33 +1,35 @@ -import java.util.concurrent.ThreadLocalRandom; - - -public class Consommateur implements Runnable { - - private BufferCirc buffer; - - public Consommateur(BufferCirc b) { - buffer = b; - } - - public Consommateur(BufferCirc b, String name) { - buffer = b; - setThName(name); - } - - public void setThName(String name) { - Thread.currentThread().setName(name); - } - - public void run() { - Integer val; - while (true) { - val = (Integer)buffer.preleve(); - System.out.println (Thread.currentThread().getName() + " a preleve " + val); - try { - Thread.sleep(ThreadLocalRandom.current().nextInt(1001)); - } - catch (InterruptedException e) {} - } - } - -} // fin classe Consommateur +import java.util.concurrent.ThreadLocalRandom; + + +public class Consommateur implements Runnable { + + private BufferCirc buffer; + + public Consommateur(BufferCirc b) { + buffer = b; + } + + public Consommateur(BufferCirc b, String name) { + buffer = b; + setThName(name); + } + + public void setThName(String name) { + Thread.currentThread().setName(name); + } + + public void run() { + Integer val; + while (true) { + val = (Integer)buffer.preleve(); + System.out.println (Thread.currentThread().getName() + " a preleve " + val); + try { + Thread.sleep(ThreadLocalRandom.current().nextInt(1001)); + } + catch (InterruptedException e) { + System.err.println("InterruptedException: " + e); + } + } + } + +} // fin classe Consommateur