Program for producer consumer


package com.demo.demo;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.stream.IntStream;

public class ProducerConsumerDemo {

public static void main(String[] args) {
BlockingQueue<String> blockingQueue = new ArrayBlockingQueue<>(2, true);
IntStream.range(0, 4).forEach(n -> {
Producer producer = new Producer(blockingQueue);
producer.start();
});
Consumer consumer = new Consumer(blockingQueue);
consumer.start();
}
}

class Consumer extends Thread {
private BlockingQueue<String> blockingQueue;

public Consumer(BlockingQueue<String> blockingQueue) {
this.blockingQueue = blockingQueue;
}

@Override
public void run() {
while (true) {
try {
String str = blockingQueue.take();
System.out.println("Consuming msg : " + str);
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

class Producer extends Thread {
private BlockingQueue<String> blockingQueue;

public Producer(BlockingQueue<String> blockingQueue) {
this.blockingQueue = blockingQueue;
}

@Override
public void run() {
int i = 0;
while (true) {
try {
String str = Thread.currentThread().getName() + i;
blockingQueue.put(str);
System.out.println("produce : " + str);
} catch (InterruptedException e) {
e.printStackTrace();
}
i = i + 1;
}
}
}

Comments

Post a Comment

Popular posts from this blog

Check if booleans are same

package com.demo.demo; public class EqualBooleanDemo {   public static void main(String[] args ) { Boolean b = true ; boolean b1 = true ; Boolean b2 = new Boolean( true ); System. out .println( "b==b1 : " +( b == b1 )); System. out .println( "b==b2 : " +( b == b2 )); System. out .println( "b2==b1 : " +( b2 == b1 )); } }
Read more

Program get max salary Female Employee in java8

import java.util.ArrayList; import java.util.List; public class FindHighestSalaryFemaleEmployee { public static void main(String[] args) { List<Employee> list = new ArrayList<Employee>(); list.add(new Employee(1, "A", Gender.MALE, 10)); list.add(new Employee(1, "B", Gender.FEMALE, 3)); list.add(new Employee(1, "C", Gender.FEMALE, 52)); list.add(new Employee(1, "D", Gender.MALE, 100)); Employee employee = list.stream().filter(n -> { return n.gender == Gender.FEMALE; }).map(n -> { n.setName("Female, " + n.getName()); return n; }).max((t1, t2) -> { if (t1.getSalary() == t2.getSalary()) { return 0; } if (t1.getSalary() > t2.getSalary()) { return 1; } return -1; }).get(); System.out.println("Name : " + employee.getName()); } private static class Employee { private int id; private String name; private Gender gender; ...
Read more