[TD_SR.git] / TD1 / exo3 / Consommateur.java

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