Implement consumer producer.

src/main/java/lab/Consumer.java

+package lab;
+
+import java.util.Random;
+
+public class Consumer extends Thread {
+
+	private final Buffer buffer;
+	private final int numberOfConsumer;
+	private final Random rnd = new Random();
+	
+	public Consumer(Buffer buffer, int numberOfConsumer) {
+		this.buffer = buffer;
+		this.numberOfConsumer = numberOfConsumer;
+	}
+	
+	@Override
+	public void run() {
+		for (int i = 0; i < 5; i++) {
+			try {
+				buffer.get(numberOfConsumer);
+				Thread.sleep(rnd.nextInt(100, 1000));
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+				return;
+			}
+		}
+	}
+	
+}

src/main/java/lab/Producer.java

+package lab;
+
+import java.util.Random;
+
+public class Producer extends Thread {
+
+	private final Buffer buffer;
+	private final int numberOfProducer;
+	private final Random rnd = new Random();
+	
+	public Producer(Buffer buffer, int numberOfProducer) {
+		this.buffer = buffer;
+		this.numberOfProducer = numberOfProducer;
+	}
+	
+	@Override
+	public void run() {
+		for (int i = 0; i < 5; i++) {
+			try {
+				buffer.put(i, numberOfProducer);
+				Thread.sleep(rnd.nextInt(1, 10));
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+				return;
+			}
+		}
+	}
+	
+}

src/main/java/lab/TestProducerConsumer.java

@@ -6,7 +6,7 @@ public class TestProducerConsumer {
         
 		Buffer buffer = new Buffer(4);
        
-		/*
+		
 		Producer p1 = new Producer(buffer, 1);
 		Producer p2 = new Producer(buffer, 2);
 		Consumer c1 = new Consumer(buffer, 1);
@@ -16,7 +16,7 @@ public class TestProducerConsumer {
         p2.start();
         c1.start();
         c2.start();
-        */
+        
     }
 }