TD1: Initial commit of exercice 3 code.

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

diff --git a/TD1/exo3/BufferCirc.java b/TD1/exo3/BufferCirc.java
new file mode 100644 (file)
index 0000000..71204cc
--- /dev/null
+++ b/TD1/exo3/BufferCirc.java
@@ -0,0 +1,57 @@
+\r
+\r
+/**\r
+ * implementation du producteur consommateur avec un buffer circulaire\r
+ */\r
+public class BufferCirc {\r
+\r
+       private Object[] tampon;\r
+       private int taille;\r
+       private int prem, der, nbObj;\r
+\r
+\r
+       public BufferCirc (int t) {\r
+               taille = t;\r
+               tampon = new Object[taille];\r
+               prem = 0;\r
+               der = 0;\r
+               nbObj = 0;\r
+       }\r
+\r
+\r
+       public boolean isEmpty() {\r
+               return nbObj == 0;\r
+       }\r
+\r
+\r
+       public boolean isFull() {\r
+               return nbObj == taille;\r
+       }\r
+\r
+\r
+       public synchronized void depose(Object obj) {\r
+               if (!isFull()) {\r
+                       nbObj++;\r
+                       tampon[prem] = obj;\r
+                       prem = (prem + 1) % taille;\r
+                       System.out.println(Thread.currentThread().getName() + " a depose " + (Integer)obj);\r
+               } else {\r
+                       System.out.println("Buffer plein pour " + Thread.currentThread().getName());\r
+               }\r
+       }\r
+\r
+\r
+       public synchronized Object preleve() {\r
+               Object outObj = null;\r
+               if (isEmpty()) {\r
+                       nbObj--;\r
+                       outObj = tampon[der];\r
+                       der = (der + 1) % taille;\r
+                       System.out.println(Thread.currentThread().getName() + " a preleve " + (Integer)outObj);\r
+               } else {\r
+                       System.out.println("Buffer vide pour " + Thread.currentThread().getName());\r
+               }\r
+               return outObj;\r
+       }\r
+\r
+} // fin class BufferCirc\r