Write a program to solve producer consumer problem in java?

Question Posted / mohan

1 Answers
1101 Views
I also Faced
E-Mail Answers

Write a program to solve producer consumer problem in java?..

Answer / Anand Kumar Jha

Here is a simple solution using BlockingQueue in Java:nn```javanimport java.util.LinkedBlockingQueue;nimport java.util.Random;nnclass Buffer {n private LinkedBlockingQueue queue = new LinkedBlockingQueue(10);n}nnclass Producer extends Thread {n private Buffer buffer;nn Producer(Buffer buffer) {n this.buffer = buffer;n }nn public void run() {n for (int i = 0; i < 5; i++) {n try {n synchronized(buffer) {n buffer.queue.put(String.valueOf(i));nbuffers.notifyAll();n Thread.sleep(100);n }n }n catch (InterruptedException e) {n e.printStackTrace();n }n }n }n}nnclass Consumer extends Thread {n private Buffer buffer;nn Consumer(Buffer buffer) {n this.buffer = buffer;n }nn public void run() {n while (true) {n try {n synchronized(buffer) {n String item = (String)buffer.queue.take();nsystem.out.println("Item: " + item);nbuffers.notifyAll();n Thread.sleep(50);n }n catch (InterruptedException e) {n e.printStackTrace();n }n }n }n}nnpublic class ProducerConsumer {n public static void main(String[] args) {n Buffer buffer = new Buffer();n Producer producer1 = new Producer(buffer);n Consumer consumer1 = new Consumer(buffer);n Producer producer2 = new Producer(buffer);n consumer1.start();n producer1.start();n producer2.start();n }n}n```

Is This Answer Correct ?

0 Yes

0 No

Post New Answer