4、关于 Object 类中的 wait 和 notify 方法。(生产者和消费者模式!)
第一:wait 和 notify 方法不是线程对象的方法,是 java 中任何一个 java 对象都有的方法,因为这两个方法是 Object 类中自带的。
wait 方法和 notify 方法不是通过线程对象调用的。
第二:wait() 方法作用?
Object o = new Object();
o.wait();
表示:让正在 o 对象上活动的线程进入等待状态,无期限等待,直到被唤醒为止。
o.wait(); 方法的调用,会让“当前线程(正在 o 对象上活动的线程)”进入等待状态。
第三:notify方法作用?
Object o = new Object();
o.notify();
表示:唤醒正在 o 对象上等待的线程。
notifyAll() 方法:
这个方法是唤醒 o 对象上处于等待的所有线程。
例:
package com.su.test.threadtest;
import java.util.ArrayList;
import java.util.List;
/**
- @author : sumeiping
- @date : 2022-02-01 16:41
- 1、使用 wait 方法和 notify 方法实现“生产者和消费者模式”
- 2、什么是“生产者和消费者模式”
-
生产线程负责生产,消费线程负责消费。
-
生产线程和消费线程要达到均衡。
-
这是一种特殊的业务需求,在这种特殊的情况下要使用 wait 方法和 notify 方法。
- 3、wait 和 notify 方法不是线程对象的方法,是普通 java 对象都有的方法。java.lang.Object 根类
- 4、wait 方法和 notify 方法建立在线程同步的基础之上。因为多线程要同时操作一个仓库。有线程安全问题。
- 5、wait 方法作用:o.wait() 让正在 o 对象上活动的线程 t 进入等待状态,并且释放掉 t 线程之前占有的 o 对象的锁。
- 6、notify 方法作用:o.notify() 让正在 o 对象上等待的线程唤醒,只是通知,不会释放 o 对象上之前占有的锁。
- 7、模拟这样一个需求:
-
仓库我们采用 List 集合。
-
List 集合中假设只能存储 1 个元素。
-
1 个元素就表示仓库满了。
-
如果 List 集合中元素个数是 0,就表示仓库空了。
-
保证 List 集合中永远都是最多存储 1 个元素。
-
必须做到这种效果:生产 1 个消费 1 个。
*/
public class WaitNotify {
public static void main(String[] args) {
// 创建一个仓库对象,共享的。
List list = new ArrayList();
// 创建2个线程对象// 生产者线程对象Thread t1 = new Thread(new Producer(list));t1.setName("生产者线程");// 消费者线程对象Thread t2 = new Thread(new Consumer(list));t2.setName("消费者线程");// 启动线程t1.start();t2.start();/*** 生产者线程--->java.lang.Object@47a2a66c* 消费者线程--->java.lang.Object@47a2a66c* 仓库已经空了* 生产者线程--->java.lang.Object@496550e8* 消费者线程--->java.lang.Object@496550e8* 仓库已经空了* 生产者线程--->java.lang.Object@4d5acd1c* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@4d5acd1c* 仓库已经空了* 生产者线程--->java.lang.Object@8585ad3* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@8585ad3* 生产者线程--->java.lang.Object@5a9b1c72* 消费者线程--->java.lang.Object@5a9b1c72* 生产者线程--->java.lang.Object@399af5d9* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@399af5d9* 生产者线程--->java.lang.Object@22b3eddb* 仓库已经有1个元素了* 消费者线程--->java.lang.Object@22b3eddb* 仓库已经空了* 生产者线程--->java.lang.Object@6877a59c* ..........*/
}
}
// 生产线程
class Producer implements Runnable{
// 仓库
private List list;
public Producer(){}
public Producer(List list) {this.list = list;
}@Override
public void run() {// 一直生产(使用死循环来模拟一直生产)while (true){// 给仓库对象list加锁synchronized (list){if (list.size() > 0){ // 大于 0,说明仓库中已经有 1 个元素了。System.out.println("仓库已经有1个元素了");try {list.wait(); // 当线程进入等待状态,并且释放 Producer 之前占有的 list 集合的锁。} catch (InterruptedException e) {e.printStackTrace();}}// 程序执行到这来说明仓库是空的,可以生产Object obj = new Object();list.add(obj);System.out.println(Thread.currentThread().getName() + "--->" + obj);try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 唤醒消费者进行消费//list.notify();list.notifyAll();}}
}
}
// 消费线程
class Consumer implements Runnable{
private List list;
public Consumer(){}
public Consumer(List list){this.list = list;
}@Override
public void run() {// 一直消费while (true){synchronized (list){if (list.size() == 0){System.out.println("仓库已经空了");try {list.wait(); // 仓库已经空了。消费者线程等待,释放掉 list 集合的锁} catch (InterruptedException e) {e.printStackTrace();}}// 程序执行到这里说明仓库中有数据,可以消费Object obj = list.remove(0);System.out.println(Thread.currentThread().getName() + "--->" + obj);try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 唤醒生产者进行生产//list.notify();list.notifyAll();}}
}
}