欢迎大家来到IT世界,在知识的湖畔探索吧!

import java.util.ArrayList;
import java.util.List;
 
public class MyList {
 
    private static List<String> list = new ArrayList<String>();
 
    public static void add() {
        list.add("aaaaa");
    }
 
    public static int size() {
        return list.size();
    }
}
 
 
public class ThreadA extends Thread {
 
    private Object lock;
 
    public ThreadA(Object lock) {
        super();
        this.lock = lock;
    }
 
    @Override
    public void run() {
        try {
            synchronized (lock) {
                if (MyList.size() != 5) {
                    System.out.println("wait begin "+ System.currentTimeMillis());
                  
                    lock.wait();
                  
                    System.out.println("wait end  "+ System.currentTimeMillis());
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
 
 
public class ThreadB extends Thread {
    private Object lock;
 
    public ThreadB(Object lock) {
        super();
        this.lock = lock;
    }
 
    @Override
    public void run() {
        try {
            synchronized (lock) {
                for (int i = 0; i < 10; i++) {
                    MyList.add();
                    if (MyList.size() == 5) {
                        lock.notify();
                        System.out.println("已经发出了通知");
                    }
                    System.out.println("添加了" + (i + 1) + "个元素!");
                    Thread.sleep(1000);
                }
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
 




public class Run {
 
    public static void main(String[] args) {
 
        try {
            Object lock = new Object();
 
            ThreadA a = new ThreadA(lock);
            a.start();
 
            Thread.sleep(50);
 
            ThreadB b = new ThreadB(lock);
            b.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

欢迎大家来到IT世界,在知识的湖畔探索吧!

线程A要等待某个条件满足时(list.size()==5)，才执行操作。

线程B则向list中添加元素，改变list 的size。

A,B之间如何通信的呢？也就是说，线程A如何知道 list.size() 已经为5了呢？

这里用到了Object类的 wait() 和 notify() 方法。

当条件未满足时(list.size() !=5)，线程A调用 wait() 放弃CPU，

并进入阻塞状态。—不需要轮询判断 那样占用CPU

当条件满足时，线程B调用 notify()通知 线程A，所谓通知线程A，就是唤醒线程A，并让它进入可运行状态。

这种方式的一个好处就是CPU的利用率提高了。

但是也有一些缺点：

比如，线程B先执行，一下子添加了5个元素并调用了notify()发送了通知，

而此时线程A还未执行，当线程A执行并调用wait()时，那它永远就不可能被唤醒了。

因为，线程B已经发了通知了，以后不再发通知了。

这说明：通知过早，会打乱程序的执行逻辑。