Producer consumer

Author: singhvirendra18gmailcom

Producer-Consumer/Attendent.java

@@ -0,0 +1,64 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.time.LocalTime;
+import java.util.Arrays;
+import java.util.List;
+
+public class Attendent implements Runnable {
+
+	private Bench bench;
+	private Integer size;
+
+	public Integer getSize() {
+		return size;
+	}
+
+	public void setSize(Integer size) {
+		this.size = size;
+	}
+
+	public Bench getBench() {
+		return bench;
+	}
+
+	public Attendent(Bench bench, Integer size) {
+		super();
+		this.bench = bench;
+		this.size = size;
+	}
+
+	public void setBench(Bench bench) {
+		this.bench = bench;
+	}
+
+	@Override
+	public void run() {
+		System.out.println("sending the next patient");
+		List<Integer> patients = bench.getPatients();
+		
+		System.out.println("Attendent" +Thread.currentThread().getName() + "stared his work at " + LocalTime.now());
+		while (LocalTime.now().isAfter(LocalTime.of(9, 0)) && LocalTime.now().isBefore(LocalTime.of(18, 0))) {
+			System.out.println("------------------------------------------------------------------------");
+			synchronized (patients) {
+				while (patients.size() == getSize()) {
+					System.err
+							.println("Bench is full of patients; No more patients can be added");
+					try {
+						patients.wait();
+					} catch (InterruptedException e) {
+						System.err.print(Thread.currentThread()
+								+ " got intruppted");
+					}
+				}
+				
+				int patientNbr=(int) (Math.random() * 100);
+				patients.add(patientNbr);
+				System.out.println(Thread.currentThread().getName() +  " sending the patient to bench " + patientNbr );
+				patients.notifyAll();
+				System.out.println("------------------------------------------------------------------------");
+			}
+		}
+
+	}
+
+}

Producer-Consumer/Bench.java

@@ -0,0 +1,21 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.util.List;
+
+public class Bench {
+
+	private List<Integer> patients;
+
+	public Bench(List<Integer> patients) {
+		this.patients = patients;
+	}
+
+	public List<Integer> getPatients() {
+		return patients;
+	}
+
+	public void setPatients(List<Integer> patients) {
+		this.patients = patients;
+	}
+
+}

Producer-Consumer/Doctor.java

@@ -0,0 +1,68 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.time.LocalTime;
+import java.util.List;
+
+public class Doctor implements Runnable {
+
+	private Bench bench;
+	private Integer size;
+
+	public Integer getSize() {
+		return size;
+	}
+
+	public void setSize(Integer size) {
+		this.size = size;
+	}
+
+	public Bench getBench() {
+		return bench;
+	}
+
+	public Doctor(Bench bench, Integer size) {
+		super();
+		this.bench = bench;
+		this.size = size;
+	}
+
+	public void setBench(Bench bench) {
+		this.bench = bench;
+	}
+
+	@Override
+	public void run() {
+		System.out.println("sending the next patient");
+		List<Integer> patients = bench.getPatients();
+		System.out.println("Doctor" +Thread.currentThread().getName() +"stared his work at " + LocalTime.now());
+		while (LocalTime.now().isAfter(LocalTime.of(9, 0))
+				&& LocalTime.now().isBefore(LocalTime.of(18, 0))) {
+			System.out.println("------------------------------------------------------------------------");
+			synchronized (patients) {
+				while (patients.size() == 0) {
+					System.out
+							.println("Bench is empty of patients; No more patients available to treat " + Thread.currentThread().getName()  + " is waiting");
+					try {
+						patients.wait();
+					} catch (InterruptedException e) {
+						System.err.print(Thread.currentThread()
+								+ " got intruppted");
+					}
+				}
+				
+				System.out.println(Thread.currentThread().getName() + " took patient from bench to treat  "
+						+  patients.get(patients.size() - 1));
+				try {
+					Thread.sleep(2000L);
+				} catch (InterruptedException e) {
+					e.printStackTrace();
+				}
+				patients.remove(patients.size() - 1);
+				patients.notifyAll();
+				System.out.println("------------------------------------------------------------------------");
+			}
+		}
+
+	}
+
+}

Producer-Consumer/Hospital.java

@@ -0,0 +1,32 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.util.ArrayList;
+
+public class Hospital {
+
+	public static void main(String[] args) {
+		
+		final Integer SIZE=10;
+		
+		Bench bench=new Bench(new ArrayList<Integer>(SIZE));
+		
+		Attendent attendent=new Attendent(bench,SIZE);
+		Thread attendentThread=new Thread(attendent);
+		attendentThread.setName("Raju");
+		attendentThread.start();
+		
+		
+		
+		Doctor doctor=new Doctor(bench,SIZE);
+		Thread docThread=new Thread(doctor);
+		docThread.setName("Sondhi");
+		docThread.start();
+		
+
+		Doctor doctor1=new Doctor(bench,SIZE);
+		Thread docThread1=new Thread(doctor1);
+		docThread1.setName("Vivek");
+		docThread1.start();
+		
+	}
+}