多线程新功能用法，求解释下 - 黑马程序员技术交流社区

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;
public class NewThreadDemo
{
public static void main(String[] args)
{
Product p = new Product();
new Thread(new ProThread(p)).start();
new Thread(new ConsThread(p)).start();
}
}
class Product
{
private int proNum = 0;
private boolean hasProduct = false;
private ReentrantLock lock = new ReentrantLock();
private Condition condition = lock.newCondition();
public void produce()
{
lock.lock();
while(true)//这里写错了，while(true)应该放在run里面的。
{
try
{
while(hasProduct)
{
System.out.println(Thread.currentThread().getName() + ":::::::wait");
condition.await();
}
System.out.println(Thread.currentThread().getName() + ":produce:" + ++proNum);
hasProduct = true;
condition.signal();
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
lock.unlock();
}
}
}
public void consume()
{
lock.lock();
try
{
while(!hasProduct)
{
System.out.println(Thread.currentThread().getName() + ":::::::wait");
try{condition.await();}catch(Exception e){e.printStackTrace();}
}
System.out.println(Thread.currentThread().getName() + "::consume::" + proNum);
hasProduct = false;
condition.signal();
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
lock.unlock();
}
}
}
class ProThread implements Runnable
{
private Product product;
ProThread(Product product)
{
this.product = product;
}
public void run()
{
product.produce();
}
}
class ConsThread implements Runnable
{
private Product product;
ConsThread(Product product)
{
this.product = product;
}
public void run()
{
while(true)
product.consume();
}
}

复制代码