首页 > 其他分享> 文章详细

Thread线程之间的通讯

2022-04-28 00:34:25 阅读：150 来源： 互联网

标签：同步 Thread notifyAll 通讯线程 notify wait

线程通讯的例子

两个线程交替打印1~100

涉及到的三个方法：

wait():一旦执行此方法，当前线程就会进入阻塞状态，并且释放同步监视器。

notify():一旦执行此方法，就会唤醒一个被wait的线程。如果有多个线程被wait，优先唤醒优先级高的线程

notifyAll():一旦执行此方法，就会唤醒所有被wait的线程。

说明：

1、wait（），notify（），notifyAll（）必须使用在同步代码块或者同步方法中。

2、wait（），notify（），notifyAll（）的调用者必须是同步代码块或者同步方法中的同步监视器。否则会出现IllegalMonitorStateException异常。

3、每个类都拥有wait（），notify（），notifyAll（）方法，因为这三个方法在上帝类Object中。

package com.gtguigu.java.Thread;

public class Number implements Runnable{
    public static void main(String[] args) {
        Number number = new Number();
        Thread thread1 = new Thread(number,"线程一");
        Thread thread2 = new Thread(number,"线程二");

        thread1.start();
        thread2.start();
    }
    private int num = 1;
    private Object obj = new Object();
    @Override
    public void run() {
        while (true){
            //同步代码块保证线程安全
            synchronized (this){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

运行结果：

如果将同步监视器改为obj对象并且没有更改notif方法和wait方法：

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

运行结果：

正确应用方法：

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                obj.notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    obj.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

notify（），wait（），notifyAll（）的调用者应该与同步监视器相同。

标签：同步,Thread,notifyAll,通讯,线程,notify,wait
来源： https://www.cnblogs.com/yu-shi-liu/p/16201199.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Thread线程之间的通讯

线程通讯的例子