多线程的问题(消费者和生产者) 消费者无法消费

m9431***

package pack01;

import java.util.ArrayList;
import java.util.List;

/**
* 测试缓存区
* @author
*
*/
public class TestBuffer {
public static void main(String[] args) {
List list = new ArrayList();//生成一个缓存区的储存器
Buffer buffer = new Buffer(list,20);//生成一个缓存区

Consumer consumer = new Consumer(buffer);//生成一个消费者
Producer producer = new Producer(buffer);//生成一个生产者

new Thread(producer).start();//启动线程
new Thread(consumer).start();

}
}

class Consumer implements Runnable//消费者
{
private Buffer buffer;//为消费者指定缓存区

public Consumer(Buffer buffer) {
//在构造器中指定缓存区
this.buffer = buffer;
}

public synchronized void consume()//消费
{
if(this.buffer.dataBuffer.size() == 0)
{
System.out.println("缓存区中无数据可消费!");
try {
this.wait();//如果缓存区中无数据可消费暂停该线程
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.buffer.dataBuffer.remove(this.buffer.dataBuffer.size()-1);
this.buffer.len--;//缓存区的当前大小减1
this.notifyAll();//消费完毕通知其他线程

}
@Override
public void run() {
for(int i = 1; i < 10; i++)
{
this.consume();
System.out.println("消费第"+i+"个数据");
}
}

}

class Producer implements Runnable//生产者
{
private Buffer buffer;//为生产者指定容器

public Producer(Buffer buffer) {
this.buffer = buffer;//在构造器中指定容器
}

public synchronized void produce(Data data)//生产
{
if(this.buffer.dataBuffer.size() == this.buffer.maxSize)//如果缓存区的大小等于缓存区的最大大小
{
System.out.println("缓存区已满!");
try {
this.wait();//如果缓存区已满就暂停该线程
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.buffer.dataBuffer.add(data);//如果不等则往缓存区中加入data
this.buffer.len++;//缓存区的当前大小加1
this.notifyAll();//生产完毕通知其他线程
}

@Override
public void run() {

for(int i = 1; i

已有账号？

找人解决需求

多线程的问题(消费者和生产者) 消费者无法消费

热门问答

m9431***

今日需求悬赏

今日问答求助

发布任务需求已有1031166位用户正在使用天盟网服务

新手帮助

平台规则

关于天盟

一键快捷导航

微信公众号

手机客户端