跳至主要內容

Thread的wait和notify

DHB大约 2 分钟Java线程

Thread的wait和notify

当不同线程之间需要通信时,就要使用到wait和notify这两个方法

wait的作用

让线程进入阻塞状态,并且会释放线程占有的锁,并交出CPU执行权限。

nofity

唤醒等待队列中的某个线程,如果时多个线程同时等待并不能指定唤醒某个线程,这有CPU来决定

notifyAll

这个方法则是唤醒等待队列中的所有线程

实践

实现一个容器,提供get和size两个方法,些两个线程,线程1添加10个元素到容器中,线程2实现监控元素的个数,当个数大于5时,线程2给出提示并结束

代码

package cn.dhbin;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * 实现一个容器,提供get和size两个方法,些两个线程,线程1添加10个元素到容器中,
 * 线程2实现监控元素的个数,当个数大于5时,线程2给出提示并结束
 * 使用Thread的wait和notify实现
 *
 * @author dhb
 */
public class Container1 {

    /**
     * 容器
     */
    private volatile List<Object> list = new ArrayList<>();


    public void add(Object obj) {
        list.add(obj);
    }

    public int size() {
        return list.size();
    }


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

        /*
        * 监控大小的线程必须先执行,因为如果添加元素线程先执行的话,添加元素线程
        * 取到了锁并不释放,监控大小的线程就无法加入while块
        * */
        new Thread(() -> {
            synchronized (lock) {
                while (c.size() != 5) {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println("容器到达5个,结束");
                    // 唤醒添加元素线程
                    lock.notify();
                }
            }
        }).start();

        TimeUnit.SECONDS.sleep(1);

        new Thread(() -> {
            synchronized (lock) {
                for (int i = 0; i < 10; i++) {
                    c.add(new Object());
                    System.out.println(Thread.currentThread().getName() + "---" + i);
                    try {
                        TimeUnit.SECONDS.sleep(1);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    if (c.size() == 5) {
                        // 通知监控大小线程,notify并不会释放锁
                        lock.notify();
                        try {
                            // wait让出cpu,让监控大小线程执行
                            lock.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }).start();

    }
}

资料

Java并发编程(一)Thread详解open in new window

上次编辑于:
贡献者: dhb,donghaibin