스레드 베이스(3)

ProducerConsumer

package org.wp.thread;

public class ProducerConsumer {
	public static void main(String args[]) {
		SyncStack ss = new SyncStack();
		Producer prod = new Producer(ss);
		Consumer cons = new Consumer(ss);
		new Thread(cons).start();
		new Thread(prod).start();
	}
}

class Vinegar {
	Integer id;

	Vinegar(Integer id) {
		this.id = id;
	}

	@Override
	public String toString() {
		return "Vinegar:" + id;
	}
}

class SyncStack {
	Integer index = 0;
	Vinegar[] arrVinegar = new Vinegar[6];

	public synchronized void produce(Vinegar vin) {
		while (index == arrVinegar.length) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		this.notify();
		arrVinegar[index] = vin;
		System.out.println("   :" + vin);
		index++;
	}

	public synchronized void consume() {
		while (index == 0) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		this.notify();
		index--;
		System.out.println("   :" + arrVinegar[index]);
	}
}

class Producer implements Runnable {
	SyncStack ss = null;

	Producer(SyncStack ss) {
		this.ss = ss;
	}

	@Override
	public void run() {
		for (int i = 0; i < 20; i++) {
			Vinegar vin = new Vinegar(i);
			ss.produce(vin);
			try {
				Thread.sleep((int) (Math.random() * 100));
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}

class Consumer implements Runnable {
	SyncStack ss = null;

	Consumer(SyncStack ss) {
		this.ss = ss;
	}

	@Override
	public void run() {
		for (int i = 0; i < 20; i++) {
			ss.consume();
			try {
				Thread.sleep((int) (Math.random() * 1000));
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}