LockSupport 原理解析(上)

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
全局流量管理 GTM,标准版 1个月
云解析 DNS,旗舰版 1个月
简介: LockSupport 原理解析

LockSupport 是什么?


解决了线程等待唤醒机制(wait/notify)


image.png


核心方法:


LockSupport 中的 park() 和 unpark() 的作用分别是阻塞线程和解除阻塞线程


线程唤醒和等待的方法


三种让线程等待和唤醒的方法


方式1: 使用 Object 中的 wait() 方法让线程等待,使用 Object 中的 notify() 方法唤醒线程。


方式2: 使用 JUC 包中 Condition 的 await() 方法让线程等待,使用 signal() 方法唤醒线程。


方式3: LockSupport 类可以阻塞当前线程以及唤醒指定被阻塞的线程。


方式1: Object 类中的 wait 和 notify 方法实现线程等待和唤醒


试验代码:


public class LockSupportDemo {
    static Object objectLock = new Object();
    public static void main(String[] args) {
        // 1、wait、notify 需要配合 synchronized 使用
        new Thread(() -> {
            // 2、唤醒线程只能唤醒当前 wait 的线程
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (objectLock) {
                System.out.println(Thread.currentThread().getName() + "\t =======> 进入锁");
                try {
                    objectLock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "\t =======> 被唤醒");
            }
        }, "A").start();
        new Thread(() -> {
            synchronized (objectLock) {
                objectLock.notify();
                System.out.println(Thread.currentThread().getName() + "\t =======> 发起通知");
            }
        }, "B").start();
    }
}


总结:


1、wait、notify 需要配合 synchronized 使用不然会抛出异常


image.png


结论:Object 类中的 wait、notify 、notifyAll 用与线程等待和唤醒的方法,都必须要在 synchronized 内部执行(必须要使用 synchronized 关键在)



2、需要先阻塞后唤醒


/**
 * 要求:t1 线程等待 3 秒,3 秒后, t2 线程唤醒 t1 线程继续工作
 *
 * 将 notify 放在 wait 方法之前执行,t1 先 notify 了, 3 秒钟后 t2 线程再执行 wait 方法
 * 现象:
 *   程序一直无法结束
 * 结论:
 *   先 wait 后 notify 、notifyAll方法、等待中的线程才会被唤醒,否则无法被唤醒
 */
public class LockSupportDemo {
    static Object objectLock = new Object();
    public static void main(String[] args) {
        new Thread(() -> {
            // 2、唤醒线程只能唤醒当前 wait 的线程
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            synchronized (objectLock) {
                System.out.println(Thread.currentThread().getName() + "\t =======> 进入锁");
                try {
                    objectLock.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + "\t =======> 被唤醒");
            }
        }, "A").start();
        new Thread(() -> {
            synchronized (objectLock) {
                objectLock.notify();
                System.out.println(Thread.currentThread().getName() + "\t =======> 发起通知");
            }
        }, "B").start();
    }
}


方式2: Condition 接口中的 await 后 singnal 方法实现线程的等待和唤醒


试验代码:


public class LockSupportConditionDemo {
    static Lock lock = new ReentrantLock();
    static Condition condition = lock.newCondition();
    public static void main(String[] args) {
        new Thread(() -> {
            lock.lock();
            try {
                System.out.println(Thread.currentThread().getName() + "\t ====== 进入锁");
                condition.await();
                System.out.println(Thread.currentThread().getName() + "\t ====== 被唤醒");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                lock.unlock();
            }
        }, "A").start();
        new Thread(() -> {
            lock.lock();
            try {
                condition.signal();
                System.out.println(Thread.currentThread().getName() + "\t ====== 通知");
            } finally {
                lock.unlock();
            }
        }, "B").start();
    }
}


结论:


1、condition 需要配合 Lock 一起使用。


2、需要先阻塞后唤醒


注:方式3 后续单独说明


传统的 synchronized 和 Lock 实现等待唤醒通知的约束


1、线程需要先获得并且持有锁,必须在锁块(synchronized 或 lock)中


2、必须要先等待后唤醒,线程才能够被唤醒


相关文章
|
26天前
|
存储 缓存 算法
HashMap深度解析:从原理到实战
HashMap,作为Java集合框架中的一个核心组件,以其高效的键值对存储和检索机制,在软件开发中扮演着举足轻重的角色。作为一名资深的AI工程师,深入理解HashMap的原理、历史、业务场景以及实战应用,对于提升数据处理和算法实现的效率至关重要。本文将通过手绘结构图、流程图,结合Java代码示例,全方位解析HashMap,帮助读者从理论到实践全面掌握这一关键技术。
75 13
|
2月前
|
运维 持续交付 云计算
深入解析云计算中的微服务架构:原理、优势与实践
深入解析云计算中的微服务架构:原理、优势与实践
83 1
|
1天前
|
机器学习/深度学习 自然语言处理 搜索推荐
自注意力机制全解析:从原理到计算细节,一文尽览!
自注意力机制(Self-Attention)最早可追溯至20世纪70年代的神经网络研究,但直到2017年Google Brain团队提出Transformer架构后才广泛应用于深度学习。它通过计算序列内部元素间的相关性,捕捉复杂依赖关系,并支持并行化训练,显著提升了处理长文本和序列数据的能力。相比传统的RNN、LSTM和GRU,自注意力机制在自然语言处理(NLP)、计算机视觉、语音识别及推荐系统等领域展现出卓越性能。其核心步骤包括生成查询(Q)、键(K)和值(V)向量,计算缩放点积注意力得分,应用Softmax归一化,以及加权求和生成输出。自注意力机制提高了模型的表达能力,带来了更精准的服务。
|
12天前
|
存储 物联网 大数据
探索阿里云 Flink 物化表:原理、优势与应用场景全解析
阿里云Flink的物化表是流批一体化平台中的关键特性,支持低延迟实时更新、灵活查询性能、无缝流批处理和高容错性。它广泛应用于电商、物联网和金融等领域,助力企业高效处理实时数据,提升业务决策能力。实践案例表明,物化表显著提高了交易欺诈损失率的控制和信贷审批效率,推动企业在数字化转型中取得竞争优势。
57 14
|
20天前
|
网络协议 安全 网络安全
探索网络模型与协议:从OSI到HTTPs的原理解析
OSI七层网络模型和TCP/IP四层模型是理解和设计计算机网络的框架。OSI模型包括物理层、数据链路层、网络层、传输层、会话层、表示层和应用层,而TCP/IP模型则简化为链路层、网络层、传输层和 HTTPS协议基于HTTP并通过TLS/SSL加密数据,确保安全传输。其连接过程涉及TCP三次握手、SSL证书验证、对称密钥交换等步骤,以保障通信的安全性和完整性。数字信封技术使用非对称加密和数字证书确保数据的机密性和身份认证。 浏览器通过Https访问网站的过程包括输入网址、DNS解析、建立TCP连接、发送HTTPS请求、接收响应、验证证书和解析网页内容等步骤,确保用户与服务器之间的安全通信。
80 1
|
2月前
|
运维 持续交付 虚拟化
深入解析Docker容器化技术的核心原理
深入解析Docker容器化技术的核心原理
60 1
|
2月前
|
存储 供应链 算法
深入解析区块链技术的核心原理与应用前景
深入解析区块链技术的核心原理与应用前景
69 0
|
2月前
|
JavaScript 前端开发 API
Vue.js响应式原理深度解析:从Vue 2到Vue 3的演进
Vue.js响应式原理深度解析:从Vue 2到Vue 3的演进
72 0
|
2月前
|
API 持续交付 网络架构
深入解析微服务架构:原理、优势与实践
深入解析微服务架构:原理、优势与实践
52 0
|
2月前
|
存储 供应链 物联网
深入解析区块链技术的核心原理与应用前景
深入解析区块链技术的核心原理与应用前景

推荐镜像

更多