Technical blog

 
 
package com.swayam.exp;
 
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
 
/**
 * 
 * @author paawak
 */
public class ProducerConsumerSimulator implements Runnable {
 
    private final int sleepInterval;
    private final List<String> list;
    private final boolean producer;
    private final boolean threadSafe;
 
    public ProducerConsumerSimulator(boolean producer, boolean threadSafe,
            int sleepInterval, List<String> list) {
        this.producer = producer;
        this.sleepInterval = sleepInterval;
        this.list = list;
        this.threadSafe = threadSafe;
    }
 
    public void run() {
 
        while (true) {
 
            try {
                Thread.sleep(sleepInterval);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
 
            if (producer) {
 
                produce();
 
                if (threadSafe) {
                    synchronized (list) {
                        System.out.println("Consumer, wake-up!!!");
                        list.notify();
                    }
                }
 
            } else {
 
                if (threadSafe) {
                    synchronized (list) {
                        try {
                            System.out.println("Waiting for producer...");
                            list.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
 
                consume();
 
            }
 
        }
 
    }
 
    private void produce() {
 
        Calendar cal = Calendar.getInstance();
 
        String str = "Time Now -- " + cal.get(Calendar.MINUTE) + ":"
                + cal.get(Calendar.SECOND) + ":"
                + cal.get(Calendar.MILLISECOND);
 
        list.add(str);
 
        System.out.println("ADDED:: " + str);
 
    }
 
    private void consume() {
 
        try {
            String str = list.remove(0);
            System.out.println("REMOVED:: " + str);
        } catch (IndexOutOfBoundsException e) {
            e.printStackTrace();
        }
 
    }
 
    /**
     * For testing
     * 
     * @param args
     * @throws InterruptedException
     */
    public static void main(String[] args) throws InterruptedException {
 
        int PRODUCER_SLEEP_INTERVAL = 1000;
        int CONSUMER_SLEEP_INTERVAL = 30;
        boolean THREAD_SAFE_EXECUTION = true;
 
        List<String> list = new ArrayList<String>();
        Thread producer = new Thread(new ProducerConsumerSimulator(true,
                THREAD_SAFE_EXECUTION, PRODUCER_SLEEP_INTERVAL, list));
        producer.start();
 
        Thread consumer = new Thread(new ProducerConsumerSimulator(false,
                THREAD_SAFE_EXECUTION, CONSUMER_SLEEP_INTERVAL, list));
        consumer.start();
 
    }
 
}