多线程学习——消费者生产者（2）

package com.daicy.ProducerConsumer;

import java.util.concurrent.LinkedBlockingQueue;

public class DLinkedBlockingQueue<E> implements IDStack<E> {

	private LinkedBlockingQueue stack = new LinkedBlockingQueue();

	@Override
	public E push(E item) throws InterruptedException {
		// TODO Auto-generated method stub
		stack.put(item);
		return item;
	}

	@Override
	public E pop() throws InterruptedException {
		// TODO Auto-generated method stub
		return (E) stack.take();
	}

}

package com.daicy.ProducerConsumer;

import java.util.Stack;

public class DStack<E> implements IDStack<E> {
	private Stack stack = new Stack();

	public synchronized E push(E item) {
		stack.push(item);
		notify();
		return item;
	}

	public synchronized E pop() throws InterruptedException {
		while (stack.size() == 0) {
			this.wait();
		}
		return (E) stack.pop();
	}

}

package com.daicy.ProducerConsumer;

public interface IDStack<E> {

	public E push(E item) throws InterruptedException;

	public E pop() throws InterruptedException;

}

package com.daicy.ProducerConsumer;

public class Mantou {
	private int id;

	Mantou(int id) {
		this.id = id;
	}

	public String toString() {
		return "Mantou :" + id;
	}
}

package com.daicy.sequence;

public class SafeSequence {
	private static int value;

	public static synchronized int getNext() {
		return value++;
	}
}