实现生产者消费者问题

Question

在下面的注释中添代码 急用
internalBuffer是LinkedList型
我还没完全学过java 自学这部分内容后编写总是有错误 希望大家帮忙 谢谢 非常谢谢@SuppressWarnings("unchecked")
public void put(Object product) {
synchronized(internalBuffer) {
if(internalBuffer.size() >= bufCount) {
//
}
//
System.out.println("Producer put: " + product + " " + this);
}
}

public Object get() {
synchronized(internalBuffer) {
Object product = null;
if(internalBuffer.isEmpty()) {
//
}
//
System.out.println("Consumer got: " + product + " " + this);
return product;
}
}

Answer 1

@SuppressWarnings("unchecked")
public void put(Object product) {
synchronized(internalBuffer) {
while(internalBuffer.size() >= bufCount) {
internalBuffer.wait();
}
internalBuffer.offer(product) );
internalBuffer.notifyAll();
System.out.println("Producer put: " + product + " " + this);
}
}public Object get() {
Object product = null;
synchronized(internalBuffer) {
while(internalBuffer.isEmpty()) {
internalBuffer.wait();
}
product.poll();
internalBuffer.notifyAll();
System.out.println("Consumer got: " + product + " " + this);
}
return product;
}
异常自己处理吧，顺便看看结构和原来的有没有差别
1.5可以使用BlockingQueue

Answer 2

product.poll();--》
product = internalBuffer.poll();

Answer 3

你看看这个：http://blog.csdn.net/afgasdg/archive/2011/04/21/6337461.aspxjava邮件系统自己写的感觉还不错 下载地址：http://download.csdn.net/source/3220522另外还可以在这里先看看运行效果：http://blog.csdn.net/afgasdg/archive/2011/04/24/6359702.aspx