-import java.util.concurrent.ThreadLocalRandom;\r
-\r
-\r
-public class Consommateur implements Runnable {\r
-\r
- private BufferCirc buffer;\r
-\r
-\r
- public Consommateur(BufferCirc b) {\r
- buffer = b;\r
- }\r
-\r
-\r
- public void run() {\r
- Integer val;\r
- while (true) {\r
- val = (Integer)buffer.preleve();\r
- System.out.println (Thread.currentThread().getName() + " a preleve " + val);\r
- try {\r
- Thread.sleep(ThreadLocalRandom.current().nextInt(1001));\r
- }\r
- catch (InterruptedException e) {}\r
- }\r
- }\r
-\r
-} // fin classe Consommateur\r
+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