关于生产者消费者视频中while循环的疑问 - 黑马程序员技术交流社区

import java.util.concurrent.locks.*;
class ProducterConsumerDemo2
{
public static void main(String[] args)
{
Resource r = new Resource(); //定义商品资源
Producter pro = new Producter(r);//创建生产者对象
Consumer son = new Consumer(r); //创建消费者对象
//创建两个生产者即两个线程
Thread t1 = new Thread(pro);
Thread t2 = new Thread(pro);
//创建两个消费者即两个线程
Thread t3 = new Thread(son);
Thread t4 = new Thread(son);
//启动四个线程并执行相应的run方法
t1.start();
t2.start();
t3.start();
t4.start();
}
}
class Resource
{
private String name; //商品的名字
private int count =1; //商品的编号
private boolean flag = false;
private Lock lock = new ReentrantLock();
private Condition condition_pro = lock.newCondition();
private Condition condition_con = lock.newCondition();
public void set(String name)throws InterruptedException
{
lock.lock();
try
{
while(flag)
condition_pro.await();
this.name = name + "--" + count++;//
System.out.println(Thread.currentThread().getName() + "...生产者 " + this.name);
flag = true;
condition_con.signal();
}
finally{
lock.unlock();//释放锁的操作一定要执行
}
}
public void out()throws InterruptedException
{
lock.lock();
try
{
while(!flag)
condition_con.await();
System.out.println(Thread.currentThread().getName() + "...消费者————" + this.name);
flag = false;
condition_pro.signal();
}finally{
lock.unlock();
}
}
}
// 商品的生产者
class Producter implements Runnable
{
private Resource res;
Producter(Resource res)
{
this.res = res;
}
public void run()
{
while(true)
{
try
{
res.set("商品+");
}
catch (InterruptedException e)
{
}
}
}
}
//商品的消费者
class Consumer implements Runnable
{
private Resource res;
Consumer(Resource res)
{
this.res = res;
}
public void run()
{
while(true)
{
try
{
res.out();
}
catch (InterruptedException e)
{
}
}
}
}

复制代码