线程通信机制-创新互联

多个线程在处理同一个资源，但是处理的动作（线程的任务）却不相同。 

等待唤醒机制就是在一个线程进行了规定操作后，另一个线程就进入等待状态（wait()），

等待刚刚进行规定操作的线程执行完他们的指定代码后，再将处于等待状态的这个线程唤醒（notify()）；

在有多个线程进行等待的时候，如果需要我们可以使用notifyAll()来唤醒所有的等待线程。

notify():
通知一个在对象上等待的线程，使其从wait方法唤醒。而唤醒的前提是该线程获取到了对象的锁。没有获取到的线程依旧处以WAITING状态。

notifyAll():
通知所有等待在该对象上的线程。

wait():
调用该方法的线程进入WAITING状态，只有等待另外线程的通知或被interrupted中断才会被唤醒。需要注意的是，调用wait()方法后，会释放对象的锁。

包子资源类

public class BaoZi {
 
    String name;//包子的名称
 
    Boolean flag;//包子的状态(true表示存在  false 表示不存在)
 
}

早餐店线程

public class ZaoCanDian extends Thread {
    BaoZi baoZi;
 
    //构造函数:用来指定线程的名称和操作资源
    public ZaoCanDian(String name, BaoZi baoZi) {
        super(name);
        this.baoZi = baoZi;
    }
 
    public void run() {
        String threadName = Thread.currentThread().getName();
        int count = 0;
        while (true) {
            synchronized (baoZi) {
                count++;
                if (count >10) {
                    break;
                }
                if (baoZi.flag) {//如果包子存在
                    try {
                        baoZi.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else {
                    //如果包子不存在
                    System.out.println(threadName + "开始制作" + baoZi.name);
                    baoZi.flag=true;//更改包子状态
                    baoZi.notify();//唤醒同一资源下的其他线程
                }
            }
        }
    }
}

吃货线程

public class ChiHuo extends Thread{
    BaoZi baoZi;
 
    //构造函数:用来指定线程的名称和操作资源
    public ChiHuo(String name,BaoZi baoZi){
        super(name);
        this.baoZi=baoZi;
    }
    public void run(){
        String threadName=Thread.currentThread().getName();
        int count=0;
        while(true){
            synchronized (baoZi){
                count++;
                if (count>10){
                    break;
                }
                if(baoZi.flag){//如果包子存在
                    System.out.println(threadName+"开始吃"+baoZi.name);
                    baoZi.flag=false;//修改状态
                    baoZi.notify();//唤醒其他资源状态
                }else{
                    //如果包子不存在
                    try {
                        baoZi.wait();//进入等待状态
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}

早餐店和吃货间线程的转换

public class ThreadTest {
    public static void main(String[] args) {
        //定义资源对象
        BaoZi baoZi=new BaoZi();
        baoZi.name="韭菜 鸡蛋 五花肉 豆腐";
        baoZi.flag=true;
 
        //定义两个线程，起名字且操作同一对象
        ChiHuo ch=new ChiHuo("空旧黎梦",baoZi);
        ZaoCanDian zcd=new ZaoCanDian("豪华",baoZi);
 
        //启动线程
        zcd.start();
        ch.start();
    }
}

你是否还在寻找稳定的海外服务器提供商？创新互联www.cdcxhl.cn海外机房具备T级流量清洗系统配攻击溯源，准确流量调度确保服务器高可用性，企业级服务器适合批量采购，新人活动首月15元起，快前往官网查看详情吧