Producer Consumer Using BlockingQueue

Author: singhvirendra18gmailcom

Producer-Consumer-BlockingQueue/Attendent.java

@@ -0,0 +1,50 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.time.LocalTime;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class Attendent implements Runnable {
+
+	private Bench bench;
+	
+	public Bench getBench() {
+		return bench;
+	}
+
+	public Attendent(Bench bench) {
+		super();
+		this.bench = bench;
+	}
+
+	public void setBench(Bench bench) {
+		this.bench = bench;
+	}
+
+	@Override
+	public void run() {
+		
+		LinkedBlockingQueue<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("------------------------------------------------------------------------");
+				
+				int patientNbr=(int) (Math.random() * 100);
+				try {
+					patients.put(patientNbr);
+					System.out.println(Thread.currentThread().getName() +  " sending the patient to bench " + patientNbr );
+					Thread.sleep(2000L);
+				} catch (InterruptedException e) {
+					e.printStackTrace();
+				}
+				
+			
+				//System.out.println("------------------------------------------------------------------------");
+			}
+		}
+
+	}
+
+

Producer-Consumer-BlockingQueue/Bench.java

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

Producer-Consumer-BlockingQueue/Doctor.java

@@ -0,0 +1,47 @@
+package org.wipo.suite.modules.administration.clients.pc;
+
+import java.time.LocalTime;
+import java.util.List;
+import java.util.Queue;
+import java.util.concurrent.LinkedBlockingQueue;
+
+public class Doctor implements Runnable {
+
+	private Bench bench;
+	
+	public Bench getBench() {
+		return bench;
+	}
+
+	public Doctor(Bench bench) {
+		super();
+		this.bench = bench;
+		
+	}
+
+	public void setBench(Bench bench) {
+		this.bench = bench;
+	}
+
+	@Override
+	public void run() {
+		LinkedBlockingQueue<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("------------------------------------------------------------------------");
+					
+				try {
+					System.out.println(Thread.currentThread().getName() + " took patient from bench to treat  " +  patients.take());
+					Thread.sleep(2000L);
+				} catch (InterruptedException e1) {
+					e1.printStackTrace();
+				
+				System.out.println("------------------------------------------------------------------------");
+			}
+		}
+
+	}}
+
+
+

Producer-Consumer-BlockingQueue/Hospital.java

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