package com.sudharsan.examples;
public class Singleton {
private Singleton() {
}
public static class LazyHolder {
private static final Singleton singleton = new Singleton();
public static Singleton getInstance() {
return singleton;
}
}
}
package com.sudharsan.examples;
import java.util.ArrayList;
import java.util.List;
class Producer implements Runnable {
private List<Integer> queue;
private int threshold;
public Producer(final List<Integer> queue, int threshold) {
this.queue = queue;
this.threshold = threshold;
}
@Override
public void run() {
for (int i = 0; i <= threshold; i++) {
try {
produce(i);
Thread.sleep(1000);
} catch (InterruptedException e) {
}
}
}
private void produce(int i) throws InterruptedException {
synchronized (this.queue) {
if (this.queue.size() == threshold) {
System.out.println(“Queue is full .. Wait for some time..” + Thread.currentThread().getName());
this.queue.wait();
}
if (this.queue.size() == 0) {
this.queue.notifyAll();
}
System.out.println(“Added element in queue: ” + i);
this.queue.add(i);
}
}
}
class Consumer implements Runnable {
private List<Integer> queue;
private int threshold;
Consumer(final List<Integer> queue, final int threshold) {
this.queue = queue;
this.threshold = threshold;
}
@Override
public void run() {
for (int i = 0; i< threshold;i++) {
try {
consume();
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
private void consume() throws InterruptedException {
synchronized (this.queue) {
if (this.queue.size() == 0) {
System.out.println(“Queue is empty… wait for some time.. ” + Thread.currentThread().getName());
this.queue.wait();
}
if (this.queue.size() == threshold) {
this.queue.notifyAll();
}
System.out.println(“Removed element from queue : ” + this.queue.remove(0));
}
}
}
public class ProducerConsumer {
static public void main(final String[] args) {
final List<Integer> list = new ArrayList<>();
final Producer1 producer = new Producer1(list, 20);
final Consumer1 consumer = new Consumer1(list, 20);
final Thread producerThread = new Thread(producer, “Producer”);
final Thread consumerThread = new Thread(consumer, “Consimer”);
producerThread.start();
consumerThread.start();
}
}
This is your very first post. Click the Edit link to modify or delete it, or start a new post. If you like, use this post to tell readers why you started this blog and what you plan to do with it.
