自己写的生产者消费者，运行异常，求帮手解决它，谢谢。 - 黑马程序员技术交流社区

package testSingle;import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;/*
* 生产者和消费者：
*
* jdk1.5以后将同步和锁封装成了对象。并将操作锁的隐式方式定义到了该对象中。将隐式动作变成了显示动作。*******************
*/class Resrouce
{
private String name;
private int count = 1;
private boolean flag = false;
Lock lock = new ReentrantLock();//定义一把锁
//通过已有的锁获取该锁上的监视器对象。
Condition con = lock.newCondition();
public void set(String name)
{
lock.lock();//获取一把锁
try
{
while(flag)
{
try
{
con.await();
}
catch (InterruptedException e)
{
// TODO: handle exception
}
}
this.name = name + count;
count++;
System.out.println(Thread.currentThread().getName()+"....生产者。。。。"+this.name);
flag = true;
con.signalAll();
}
catch (Exception e)
{
// TODO: handle exception
}
finally
{
lock.unlock();
}
}
public void out()
{
lock.lock();//获取锁
try
{
while(!flag)
{
try
{
con.await();
}
catch (InterruptedException e)
{
// TODO: handle exception
}
}
System.out.println(Thread.currentThread().getName()+"-----------------消费者-"+ this.name);
flag = false;
con.signalAll();
}
catch (Exception e)
{
// TODO: handle exception
}
finally
{
lock.unlock();
}
}
}
//生产者
class Producer implements Runnable
{
private Resrouce r;
Producer(Resrouce r)
{
this.r = r;
} @Override
public void run()
{
// TODO Auto-generated method stub
while(true)
r.set("馒头");
}
}
//消费者
class Consumer implements Runnable
{
private Resrouce r;
Consumer(Resrouce r)
{
this.r = r;
} @Override
public void run()
{
// TODO Auto-generated method stub
while(true)
r.out();
}
}
public class ResourceTest
{ /**
* @param args
*/
public static void main(String[] args)
{
// TODO Auto-generated method stub
Resrouce r = new Resrouce();
Consumer c1 = new Consumer(r);
Consumer c2 = new Consumer(r);
Producer p1 = new Producer(r);
Producer p2 = new Producer(r);
Thread t1 = new Thread(p1);
t1.start();
Thread t2 = new Thread(p2);
t2.start();
Thread t3 = new Thread(c1);
t3.start();
Thread t4 = new Thread(c2);
t4.start(); }}

复制代码

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class ProducerCustomer {
public static void main(String[] args) {
// TODO Auto-generated method stub
Goods good = new Goods();
new Thread(new Consumer(good)).start();
new Thread(new Producer(good)).start();
}
}
/**
* 生产者
* @author Panda
*
*/
class Producer implements Runnable{
Goods good = null;
public Producer(Goods good){
this.good = good;
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
LockInstance.lockEg.lock();
try {
while(good.flag){//true的时候不生产
LockInstance.proCondtion.await();
}
good.set("商品");
good.flag = true;
LockInstance.conCondtion.signal();
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
LockInstance.lockEg.unlock();
}
}
}
}
/**
* 消费者
* @author Panda
*
*/
class Consumer implements Runnable{
Goods good = null;
public Consumer(Goods good){
this.good = good;
}
@Override
public void run() {
while(true){
LockInstance.lockEg.lock();
try {
while(!good.flag){
LockInstance.conCondtion.await();
}
good.show();
good.flag = false;
LockInstance.proCondtion.signal();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
LockInstance.lockEg.unlock();
}
}
}
}
/**
* 所有相关的锁的相关实例，为了方便操作，因而全部采用共有
* @author Panda
*
*/
class LockInstance{
public static Lock lockEg = new ReentrantLock();
public static Condition proCondtion = lockEg.newCondition();//生产者条件
public static Condition conCondtion = lockEg.newCondition();//消费者条件
}
class Goods{
int num = 0;
String name;
boolean flag = false;//为
/**
* 模拟生产商品
*/
public void set(String name){
this.name=name;
num++;
System.out.println(Thread.currentThread().getName()+"生产第"+num+"件"+name);
}
/**
* 模拟消费商品
*/
public void show(){
System.out.println(Thread.currentThread().getName()+"消费第"+num+"件"+name);
}
}

复制代码