多线程系列第(三)篇---notify和notifyAll

这三个方法都必须在synchronized方法或者synchronized块中使用,否则会抛异常java.lang.IllegalMonitorStateException

wait

放弃当前资源的占有权,等啊等,直到有人通知我,才会运行wait之后的代码

notify和notifyAll

notify,唤醒一个正在等待该对象的线程。
notifyAll,唤醒所有正在等待该对象的线程。

两者相同点
都只是让线程退出等待状态,退出等待状态的线程仍然需要等待对象锁的释放

两者的不同点
前者只是通知一个线程(至于是哪个线程就看JVM了),后者是通知所有的线程。
只有被通知的线程才有机会在拿到锁之后执行wait之后的代码。

notify代码示例
public class NotifyDemo {

public synchronized void waitMethod(String name) {
    System.out.println(name + " begin");
    try {
        wait();
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    System.out.println(name + " end");
}

public synchronized void notifyMethod(String name) {
    System.out.println(name + " begin");
    notify();
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    System.out.println(name + " end");
}

class WaitThread extends Thread {

    private NotifyDemo notifyDemo;

    public WaitThread(String name, NotifyDemo notifyDemo) {
        super(name);
        this.notifyDemo = notifyDemo;
    }

    public void run() {
        notifyDemo.waitMethod(getName());
    }
}

class NotifyThread extends Thread {

    private NotifyDemo notifyDemo;

    public NotifyThread(String name, NotifyDemo notifyDemo) {
        super(name);
        this.notifyDemo = notifyDemo;
    }

    public void run() {
        notifyDemo.notifyMethod(getName());
    }
}

public static void main(String[] args) {
    NotifyDemo demo = new NotifyDemo();
    WaitThread t1 = demo.new WaitThread("等待线程1", demo);
    WaitThread t2 = demo.new WaitThread("等待线程2", demo);
    NotifyThread t3 = demo.new NotifyThread("唤醒线程3", demo);
    t1.start();
    t2.start();
    
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    t3.start();
  }
}

运行结果
等待线程1 begin
等待线程2 begin
唤醒线程3 begin
唤醒线程3 end
等待线程1 end
notifyAll代码示例
public class NotifyAllDemo {

public synchronized void waitMethod(String name) {
    System.out.println(name + " begin");
    try {
        wait();
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    System.out.println(name + " end");
}

public synchronized void notifyMethod(String name) {
    System.out.println(name + " begin");
    notifyAll();
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    System.out.println(name + " end");
}

class WaitThread extends Thread {

    private NotifyAllDemo notifyDemo;

    public WaitThread(String name, NotifyAllDemo notifyDemo) {
        super(name);
        this.notifyDemo = notifyDemo;
    }

    public void run() {
        notifyDemo.waitMethod(getName());
    }
}

class NotifyThread extends Thread {

    private NotifyAllDemo notifyDemo;

    public NotifyThread(String name, NotifyAllDemo notifyDemo) {
        super(name);
        this.notifyDemo = notifyDemo;
    }

    public void run() {
        notifyDemo.notifyMethod(getName());
    }
}

public static void main(String[] args) {
    NotifyAllDemo demo = new NotifyAllDemo();
    WaitThread t1 = demo.new WaitThread("等待线程1", demo);
    WaitThread t2 = demo.new WaitThread("等待线程2", demo);
    NotifyThread t3 = demo.new NotifyThread("唤醒线程3", demo);
    t1.start();
    t2.start();
    
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    t3.start();
  }
}

运行结果
等待线程1 begin
等待线程2 begin
唤醒线程3 begin
唤醒线程3 end
等待线程2 end
等待线程1 end
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 本文出自 Eddy Wiki ,转载请注明出处:http://eddy.wiki/interview-java.h...
    eddy_wiki阅读 2,252评论 0 14
  • 该文章转自:http://blog.csdn.net/evankaka/article/details/44153...
    加来依蓝阅读 7,395评论 3 87
  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 3,008评论 1 18
  • 本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。 首先讲...
    李欣阳阅读 2,517评论 1 15
  • 写在前面的话: 这篇博客是我从这里“转载”的,为什么转载两个字加“”呢?因为这绝不是简单的复制粘贴,我花了五六个小...
    SmartSean阅读 4,809评论 12 45