生产者和消费者必须使用同步代码块包裹起来，保证等待和唤醒只能有一个执行，同步使用的锁对象必须保证唯一
Thread中重要方法
void wait() 在其他线程调用此对象的notify()方法或notifyall()方法前，导致当前线程等待
void notify() 唤醒在此对象监视器上等待的单个线程后，会继续执行wait方法之后的代码
void notifyAll() 唤醒所有等待线程
void wait(long m)在毫秒结束之后，还没有被notify唤醒，就会自动醒来，线程睡醒进入到Runnable/blocke状态
void sleep(long m)在毫秒结束之后，线程睡醒进入到Runnable/blocke状态
使用
我们自己创建线程类的子类时，不要忘了写上继承extend。再run()方法中写入线程同步的代码，在客户端调用时，直接调用start方法，默认自动调用run方法的代码。
实例
产品类
public class Product {
//属性代表该产品是否还有
boolean flag=false;
}
//生产者类
public class Producer extends Thread{
private Product pr;
//构造有参构造函数，让产品类实例的对象作为锁对象
public Producer(Product pr){
this.pr=pr;
}
@Override
public void run() {
//一直生产该商品
while (true){
//使用锁对象
synchronized (pr){
//如果该产品还存在，
if(pr.flag==true){
try {
//生产者停止生产
pr.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//否则生产者开始生产
System.out.println("生产者正在生产");
try {
//生产时间为5秒
Thread.sleep(5000);
System.out.println("请等待5秒");
} catch (InterruptedException e) {
e.printStackTrace();
}
//生产完成
pr.flag=true;
//唤醒消费者
pr.notify();
System.out.println("生产者生产完了，消费之开始使用");
}
}
}
}
//消费者类
public class Consumer extends Thread{
private Product pr;
//郑州人流医院 http://mobile.zzzzyy120.com/
public Consumer(Product pr){
this.pr=pr;
}
@Override
public void run() {
//消费者一直消费产品
while (true){
//锁对象
synchronized (pr){
//如果产品没有了
if (pr.flag==false){
try {
//则消费者进行等待
pr.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//如果产品还有，消费者使用产品
System.out.println("消费者正在使用");
//消耗完产品，改变产品属性
pr.flag=false;
//唤醒生产者，等待再次生产产品
pr.notify();
System.out.println("产品已经使用完了，生产者开始生产");
}
}
}
}
//主函数
public static void main(String[] args) {
//实例化产品
Product pr=new Product();
//实例化生产者，并运行run方法
new Producer(pr).start();
//实例化消费者，并运行run方法
new Consumer(pr).start();
}
运行结果
原文地址：https://www.cnblogs.com/djw12333/p/12096446.html