java 线程通信

Z时代
2024-01-10
分类：综合

java

java 线程通信使用
wait notify 配合synchronized
当线程执行wait()时，会把当前的锁释放，然后让出CPU，进入等待状态。
当执行notify/notifyAll方法时，会唤醒一个处于等待该对象锁的线程，然后继续往下执行，直到执行完退出对象锁锁住的区域（synchronized修饰的代码块）后再释放锁。

如下代码：

public class ThreadTest {

    //声明一个线程可视化的list集合
    public static List<String> list = new ArrayList<>();

    public static void main(String[] args) {
        Object lock = new Object();

        Thread t1 = new Thread(new Runnable() {
            @Override
            public void run() {
                synchronized (lock) {
                    for (int i = 0; i < 10; i++) {
                        list.add("lenny");
                        System.out.println(Thread.currentThread().getName() + "往list增加了新项目");
                        if (list.size() == 5) {
                            lock.notify(); //通知lock挂起的线程 继续执行 synchronized 块代码 执行完成后 释放锁
                            System.out.println("当前线程：" + Thread.currentThread().getName() + "，已经发出通知");
                        }
                    }
                }
            }
        }, "t1");

        Thread t2 = new Thread(new Runnable() {
            @Override
            public void run() {
                synchronized (lock) {
                    if (list.size() != 5) {
                        try {
                            lock.wait(); //此处线程挂起 释放lock
                            System.out.println("list长度"+list.size());
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.println("当前线程：" + Thread.currentThread().getName() + "，收到通知");
                }
            }
        }, "t2");

        t2.start();
        t1.start();
    }
}