wait与notify的使用

🎈专栏链接:多线程相关知识详解

wait是Object类里面的方法,而Object类是所有类的父类,所以所有的类都可以使用wait方法

wait里面包含着3个操作:

①释放当前锁

②进入阻塞等待

③其他线程调用notify的时候,可以将其唤醒并尝试重新获取锁

public class Demo2 {
    public static void main(String[] args) {
        Object object = new Object();
 
        Thread t1 = new Thread(() -> {
            while (true){
                synchronized (object){
                    try {
                        System.out.println("wait之前");
                        object.wait();//线程阻塞等待
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                    //下面的代码只能在notify唤醒线程之后才能执行
                    System.out.println("wait之后");
                }
            }
        });
        t1.start();
        try {
            Thread.sleep(500);//确保上面这个线程已经进行阻塞等待,防止上面的线程与下面的线程发生抢占式执行
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
 
        Thread t2 = new Thread(() -> {
            while (true){
                synchronized (object){
                    System.out.println("notify之前");
                    object.notify();
                    System.out.println("notify之后");
                }
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        });
 
        t2.start();
    }
}

wait和notify能够控制多线程之间的执行先后顺序

wait和notify使用时需要注意的四点:

1.都要搭配synchronized来进行使用

2.wait和notify得使用同一个对象,才是有效的

3.用来加锁的对象和wait/notify对象也得一致

4.即使当前没有线程在wait,直接notify也不会有副作用

当有多个线程wait等待的时候,由于线程的抢占式执行,所以notify所唤醒的线程也是不确定的,需要看系统调度,除非是多个不同对象的wait,使用不同对象的notify,各自唤醒各自的,如果是一个对象在好几个线程里都wait,不能指定唤醒也可以直接使用notifyAll方法直接将所有的线程直接唤醒

wait还有一个重载版本,参数可以传时间,表示等待的最大时间,下面这个代码是该方法的源代码

timeout – the maximum time to wait in milliseconds.(以毫秒为单位的最大等待时间)

nanos – additional time, in nanoseconds range 0-999999.(额外时间，以纳秒为单位，范围为0-999999)

public final void wait(long timeout, int nanos) throws InterruptedException {
        if (timeout < 0) {
            throw new IllegalArgumentException("timeout value is negative");
        }
 
        if (nanos < 0 || nanos > 999999) {
            throw new IllegalArgumentException(
                                "nanosecond timeout value out of range");
        }
 
        if (nanos > 0) {
            timeout++;
        }
 
        wait(timeout);
    }