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

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

20191031000647205.png


概述


官方指导: 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)) {
                    @Override
                    public 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") {
              @Override
              public void run() {
                  anotherThink();
              }
          }.start() 
      **/
        new Thread(() ->  anotherThink()  ,"Test Thread").start();
        Thread.sleep(1000);
        synchronized (LOCK) {
            LOCK.notify();
        }
    }

运行日志


20191027225410640.png

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

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

相关文章
|
6天前
|
安全 Java 调度
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第12天】 在现代软件开发中,多线程编程是提升应用程序性能和响应能力的关键手段之一。特别是在Java语言中,由于其内置的跨平台线程支持,开发者可以轻松地创建和管理线程。然而,随之而来的并发问题也不容小觑。本文将探讨Java并发编程的核心概念,包括线程安全策略、锁机制以及性能优化技巧。通过实例分析与性能比较,我们旨在为读者提供一套既确保线程安全又兼顾性能的编程指导。
|
6天前
|
安全 前端开发 程序员
|
2天前
|
Java 程序员 调度
Java中的多线程编程:基础知识与实践
【5月更文挑战第19天】多线程编程是Java中的一个重要概念,它允许程序员在同一时间执行多个任务。本文将介绍Java多线程的基础知识,包括线程的创建、启动和管理,以及如何通过多线程提高程序的性能和响应性。
|
3天前
|
Java
深入理解Java并发编程:线程池的应用与优化
【5月更文挑战第18天】本文将深入探讨Java并发编程中的重要概念——线程池。我们将了解线程池的基本概念,应用场景,以及如何优化线程池的性能。通过实例分析,我们将看到线程池如何提高系统性能,减少资源消耗,并提高系统的响应速度。
13 5
|
3天前
|
消息中间件 安全 Java
理解Java中的多线程编程
【5月更文挑战第18天】本文介绍了Java中的多线程编程,包括线程和多线程的基本概念。Java通过继承Thread类或实现Runnable接口来创建线程,此外还支持使用线程池(如ExecutorService和Executors)进行更高效的管理。多线程编程需要注意线程安全、性能优化和线程间通信,以避免数据竞争、死锁等问题,并确保程序高效运行。
|
3天前
|
安全 Java 容器
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第18天】随着多核处理器的普及,并发编程变得越来越重要。Java提供了丰富的并发编程工具,如synchronized关键字、显式锁Lock、原子类、并发容器等。本文将深入探讨Java并发编程的核心概念,包括线程安全、死锁、资源竞争等,并分享一些性能优化的技巧。
|
3天前
|
安全 Java 开发者
Java中的多线程编程:理解与实践
【5月更文挑战第18天】在现代软件开发中,多线程编程是提高程序性能和响应速度的重要手段。Java作为一种广泛使用的编程语言,其内置的多线程支持使得开发者能够轻松地实现并行处理。本文将深入探讨Java多线程的基本概念、实现方式以及常见的并发问题,并通过实例代码演示如何高效地使用多线程技术。通过阅读本文,读者将对Java多线程编程有一个全面的认识,并能够在实际开发中灵活运用。
|
4天前
|
存储 关系型数据库 MySQL
《MySQL 入门教程》第 05 篇 账户和权限,Java高并发编程详解深入理解pdf
《MySQL 入门教程》第 05 篇 账户和权限,Java高并发编程详解深入理解pdf
|
6天前
|
安全 Java 开发者
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第15天】本文将深入探讨Java并发编程的核心概念,包括线程安全和性能优化。我们将通过实例分析,理解线程安全的重要性,并学习如何通过各种技术和策略来实现它。同时,我们也将探讨如何在保证线程安全的同时,提高程序的性能。
|
6天前
|
消息中间件 并行计算 Java
Java中的多线程编程:基础知识与实践
【5月更文挑战第15天】 在现代计算机编程中,多线程是一个复杂但必不可少的概念。特别是在Java这种广泛使用的编程语言中,理解并掌握多线程编程是每个开发者必备的技能。本文将深入探讨Java中的多线程编程,从基础概念到实际应用场景,为读者提供全面的理论支持和实践指导。

热门文章

最新文章