概述

官方指导： https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html

或者：

https://learning.oreilly.com/library/view/the-java-language/9780133260335/ch17lev1sec2.html

关于wait set

Every object, in addition to having an associated monitor, has an associated wait set. A wait set is a set of threads.
A wait set is a set of threads.
When an object is first created, its wait set is empty. Elementary actions that add threads to and remove threads from wait sets are atomic. Wait sets are manipulated solely through the methods Object.wait, Object.notify, and Object.notifyAll.
Wait set manipulations can also be affected by the interruption status of a thread, and by the Thread class’s methods dealing with interruption. Additionally, the Thread class’s methods for sleeping and joining other threads have properties derived from those of wait and notification actions.

意思是说

每个对象除具有关联的监视器外，还具有关联wait set。
wait set是一组线程
首次创建对象时，其wait set为空。将线程添加到wait set中或从wait set中删除线程的基本操作是原子的。wait set完全通过方法操作Object.wait，Object.notify和Object.notifyAll
wait set操作也可能受线程的中断状态以及Thread处理中断的类的方法的影响。此外，Thread该类用于休眠和加入其他线程的方法具有从等待和通知操作的属性派生的属性。

示例

package com.artisan.test;import java.util.Optional;
import java.util.stream.IntStream;public class WaitSet {// 显示定义一个锁private static final Object LOCK = new Object();public static void main(String[] args) throws InterruptedException {IntStream.rangeClosed(1, 10).forEach(i ->new Thread(String.valueOf("T_" + i)) {@Overridepublic void run() {synchronized (LOCK) {try {Optional.of(Thread.currentThread().getName() + " will come into wait set ..").ifPresent(System.out::println);LOCK.wait();Optional.of(Thread.currentThread().getName() + " will leave from wait set ...").ifPresent(System.out::println);} catch (InterruptedException e) {e.printStackTrace();}}}}.start());// 主线程休眠一秒，确保上面的10个线程都start  ，不然的话 有可能 线程已经进入wait set ,10个线程还没都启动，就已经有线程离开 wait set了Thread.sleep(1_000);System.out.println("=====================10个线程启动完毕=======================");// 主线程中 每次notify 1个IntStream.rangeClosed(1, 10).forEach(i -> {synchronized (LOCK) {LOCK.notify();try {// 为了方便观察 休眠1秒Thread.sleep(1_000);} catch (InterruptedException e) {e.printStackTrace();}}});Thread.sleep(1_000);System.out.println("=====================OVER=======================");}}

运行结果：

T_1 will come into wait set ..
T_8 will come into wait set ..
T_7 will come into wait set ..
T_6 will come into wait set ..
T_5 will come into wait set ..
T_4 will come into wait set ..
T_3 will come into wait set ..
T_2 will come into wait set ..
T_10 will come into wait set ..
T_9 will come into wait set ..
=====================10个线程启动完毕=======================
T_1 will leave from wait set ...
T_8 will leave from wait set ...
T_7 will leave from wait set ...
T_4 will leave from wait set ...
T_5 will leave from wait set ...
T_6 will leave from wait set ...
T_10 will leave from wait set ...
T_2 will leave from wait set ...
T_3 will leave from wait set ...
T_9 will leave from wait set ...
=====================OVER=======================Process finished with exit code 0

根据官网和我们的验证，总结一下

所有的对象都会有一个wait set,用来存放调用了该对象wait方法之后进入block状态线程
线程被notify之后，不一定立即得到执行
线程从wait set中被唤醒顺序不一定是FIFO,啥顺序，JVM规范中并没有给出，各个虚拟机的厂商有各自的实现

思考

有个方法如下：

 private static void anotherThink() {synchronized (LOCK) {System.out.println("anotherThink begin to execute....");try {Optional.of(Thread.currentThread().getName() + " will come into wait set ...").ifPresent(System.out::println);LOCK.wait();} catch (InterruptedException e) {e.printStackTrace();}Optional.of(Thread.currentThread().getName() + " will leave from wait set ...").ifPresent(System.out::println);}}

Q: 拿到锁后的第一件事情是输出一行日志 anotherThink begin to execute.... 当线程1，抢到锁后，调用wait，放弃了执行权。如果线程1被唤醒时，肯定要先获取到锁才能够执行，那我们刚才说的抢到锁后打印日志会不会被执行呢？

我们来验证下

main方法中测试代码如下

 public static void main(String[] args) throws InterruptedException {/**  new Thread("Test_Thread") {@Overridepublic void run() {anotherThink();}}.start() **/new Thread(() ->  anotherThink()  ,"Test Thread").start();Thread.sleep(1000);synchronized (LOCK) {LOCK.notify();}}

运行日志

根据测试结论可知，是不会打印第一行的。而是紧接着wait后面的代码执行，主要是源于JVM内部会记录上次代码的执行地址，进行地址恢复，继续执行。

A：所以线程被唤醒后，必须重新获取锁，但是JVM内部会进行地址恢复，直接继续上次线程后续的逻辑

高并发编程-Wait Set 多线程的“休息室”相关推荐

高并发编程-02-创建多线程的7种方式
转载于:https://blog.51cto.com/huangguizhao/2059875
java高并发多线程架构_《Java高并发编程详解-多线程架构与设计》线程安全与数据同步...
定义共享资源:多个线程对同一资源访问(读写) 线程安全:多个线程对同一资源访问的数据是一致的. Synchronized使用同步方法同步代码块深入 synchronized关键字 p66-67 ...
Java JUC高并发编程(一)
目录一.概述二.Lock接口三.线程间的通信解决虚假唤醒问题 Lock通信示例: 四.线程间定制化通信一.概述 JUC就是java.util.concurrent工具包的简称,这是一个处理线 ...
高并发编程-使用wait和notifyAll进行线程间的通信3_多线程下的生产者消费者模型和notifyAll
文章目录概述解决办法概述高并发编程-线程通信_使用wait和notify进行线程间的通信2_多生产者多消费者导致程序假死原因分析中分析了假死的原因,这里我们来看下改如何解决在多线程下出现的这 ...
【云风skynet】详解skynet的多核高并发编程丨actor模型丨游戏开发丨游戏服务端开发丨多线程丨Linux服务器开发丨后端开发
skynet中多核高并发编程给我们的启发 1. 多核并发编程 2. actor模型详解 3. 手撕一个万人同时在线游戏视频讲解如下,点击观看: [云风skynet]详解skynet的多核高并发编程丨 ...
高并发编程_高并发编程系列：7大并发容器详解（附面试题和企业编程指南）...
不知道从什么时候起,在Java编程中,经常听到Java集合类,同步容器.并发容器,高并发编程成为当下程序员需要去了解掌握的技术之一,那么他们有哪些具体分类,以及各自之间的区别和优劣呢? 只有把这些梳理 ...
高并发编程-重新认识Java内存模型（JMM）
文章目录从CPU到内存模型内存模型如何确保缓存一致性并发变成需要解决的问题 (原子性.可见性.有序性) 内存模型需要解决的问题 Java内存模型 JMM的API实现原子性 synchroniz ...
高并发编程-Thread_正确关闭线程的三种方式
文章目录概述 stop() Deprecated 方式一设置开关方式二调用interrupt API 方式三暴力结束线程-> Daemon Thread + interrupt API ...
Java 面试知识点解析(二)——高并发编程篇
前言: 在遨游了一番 Java Web 的世界之后,发现了自己的一些缺失,所以就着一篇深度好文:知名互联网公司校招 Java 开发岗面试知识点解析 ,来好好的对 Java 知识点进行复习和学习一番,大 ...

高并发编程-Wait Set 多线程的“休息室”

文章目录

概述

关于wait set

示例

思考

高并发编程-Wait Set 多线程的“休息室”相关推荐

最新文章

热门文章