多线程12/线程通信

电玩女神 2023-10-04 16:39 32阅读 0赞

#### 线程通信的例子:使用两个线程打印1-100。线程1，线程2交替打印 ####

##### 前置知识： #####

1.  **wait();** 一旦执行此方法，当前线程就进入阻塞状态，并释放同步监视器。
2.  **notify();** 一旦执行此方法，就会唤醒被wait的一个线程。如果有多个线程被wait，就唤醒优先级高的那个。
3.  **notifyAll();** 一旦执行此方法，就会唤醒所有被wait的线程。

**注意：wait()，notify()， notifyALL()三个方法必须使用在同步代码块或同步方法中。**

--------------------

> 普通做法：

package com.dxc;
    
    class Number implements Runnable{
        
        private int number = 1;
        @Override
        public void run() {
        
    
            while (true){
        
                //this指的唯一的Number对象
                synchronized (this) {
        
                    if (number <= 100){
        
                        System.out.println(Thread.currentThread().getName()+":"+number);
                        number++;
                    }else{
        
                        break;
                    }
                }
            }
        }
    }
    public class CommunicationTest {
        
        public static void main(String[] args) {
        
            Number number = new Number();
            Thread t1 = new Thread(number);
            Thread t2 = new Thread(number);
    
            t1.setName("线程1");
            t2.setName("线程2");
    
            t1.start();
            t2.start();
    
        }
    }

> 结果，无安全问题，但是会出现一个线程到底的问题

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA_size_16_color_FFFFFF_t_70]

> 完善：  
> 添加wait();方法，执行wait时会进入等待，并且释放锁（代码中省略了this）  
> 添加notify();方法，唤醒另一个线程（代码中省略了this）  
> 题目中的this指的是Number的对象

package com.dxc;
    
    class Number implements Runnable{
        
        private int number = 1;
        @Override
        public void run() {
        
    
            while (true){
        
                //this指的唯一的Number对象
                synchronized (this) {
        
                    //唤醒另一个线程
                    notify();
    
                    if (number <= 100){
        
                        System.out.println(Thread.currentThread().getName()+":"+number);
                        number++;
    
                        try {
        
                            //使得调用如下wait()方法的线程进入阻塞状态
                            wait();
                        } catch (InterruptedException e) {
        
                            e.printStackTrace();
                        }
    
                    }else{
        
                        break;
                    }
                }
            }
        }
    }
    public class CommunicationTest {
        
        public static void main(String[] args) {
        
            Number number = new Number();
            Thread t1 = new Thread(number);
            Thread t2 = new Thread(number);
    
            t1.setName("线程1");
            t2.setName("线程2");
    
            t1.start();
            t2.start();

> 结果，符合题意

![在这里插入图片描述][55b3989673ab4f0b960316d4b30661a5.png]

> 面试题: sLeep()和wait()的异同?  
> 1.相同点:一旦执行方法，都可以使得当前的线程进入阻塞状态。  
> 2.不同点:  
> 1）两个方法声明的位置不同: Thread类中声明sLeep() , object类中声明wait()  
> 2）调用的要求不同: sLeep()可以在任何需要的场景下调用。wait()必须使用在同步代码块或同步方法中  
> 3）关于是否释放同步监视器:如果两个方法都使用在同步代码块或同步方法中，**sleep()不会释放锁，wait()会释放锁**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/ada235a02ef34aaca6a4f668d1d43642.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80ODA2MzY2MA==,size_16,color_FFFFFF,t_70
[55b3989673ab4f0b960316d4b30661a5.png]: https://img-blog.csdnimg.cn/55b3989673ab4f0b960316d4b30661a5.png