【Spring源码】单例创建期间进行同步可能会导致死锁?

简介: 通过这个标题我们就可以思考本次的阅读线索了,看起来可以学到不少东西。1. 旧代码的死锁是怎么产生的。2. 贡献者通过改变什么来解决本次PR的问题呢?而阅读线索2的答案也显而易见,就是上文提到的通过后台线程来创建Micrometer单例...

在这里插入图片描述

相信大家碰到源码时经常无从下手🙃,不知道从哪开始阅读,面对大量代码晕头转向,索性就读不下去了,又浪费了一次提升自己的机会😭。


我认为有一种方法,可以解决大家的困扰!那就是通过阅读某一次开源的【PR】,从这个入口出发去阅读源码!!


至此,我们发现自己开始从大量堆砌的源码中脱离开来😀,柳暗花明又一村。

一、前瞻

Ok,开始我们今天的PR阅读

在这里插入图片描述

我们看下PR的标题,翻译过来是在单例创建期间进行同步可能会导致死锁

通过这个标题我们就可以思考本次的阅读线索了,看起来可以学到不少东西:

  1. 旧代码的死锁是怎么产生的
  2. 贡献者通过改变什么来解决死锁呢

二、探索

Ok,我们来整体看下PR的所有提交。

在这里插入图片描述

代码涉及修改了Bean创建工厂、Spring IOC容器的上下文,猜测是在bean创建过程进行修复。

而且大家注意下提交下面这行提交注释Introduce background bootstrapping for individual singleton beans为单个单例引入后台引导。

在这里插入图片描述

看下在ConfigurableBeanFactory类中确实引入了一个线程,那我们就来看看引入的这个线程具体做了什么工作。

    @Nullable
    private CompletableFuture<?> preInstantiateSingleton(String beanName, RootBeanDefinition mbd) {
   
   
        if (mbd.isBackgroundInit()) {
   
   
            Executor executor = getBootstrapExecutor(); // 获取Executor
            if (executor != null) {
   
   
                String[] dependsOn = mbd.getDependsOn();
                if (dependsOn != null) {
   
   
                    for (String dep : dependsOn) {
   
   
                        getBean(dep);
                    }
                }
                CompletableFuture<?> future = CompletableFuture.runAsync(
                        () -> instantiateSingletonInBackgroundThread(beanName), executor);
                addSingletonFactory(beanName, () -> {
   
   
                    try {
   
   
                        future.join();
                    }
                    catch (CompletionException ex) {
   
   
                        ReflectionUtils.rethrowRuntimeException(ex.getCause());
                    }
                    return future;  // not to be exposed, just to lead to ClassCastException in case of mismatch
                });
                return (!mbd.isLazyInit() ? future : null);
            }
            else if (logger.isInfoEnabled()) {
   
   
                logger.info("Bean '" + beanName + "' marked for background initialization " +
                        "without bootstrap executor configured - falling back to mainline initialization");
            }
        }
        if (!mbd.isLazyInit()) {
   
   
            instantiateSingleton(beanName);
        }
        return null;
    }

可以看到这段核心代码通过getBootstrapExecutor获取该线程后,再通过该Executor线程去执行了instantiateSingletonInBackgroundThread方法。

    private void instantiateSingletonInBackgroundThread(String beanName) {
   
   
        this.preInstantiationThread.set(PreInstantiation.BACKGROUND);
        try {
   
   
            instantiateSingleton(beanName);
        }
        catch (RuntimeException | Error ex) {
   
   
            if (logger.isWarnEnabled()) {
   
   
                logger.warn("Failed to instantiate singleton bean '" + beanName + "' in background thread", ex);
            }
            throw ex;
        }
        finally {
   
   
            this.preInstantiationThread.set(null);
        }
    }

    private void instantiateSingleton(String beanName) {
   
   
        if (isFactoryBean(beanName)) {
   
   
            Object bean = getBean(FACTORY_BEAN_PREFIX + beanName);
            if (bean instanceof SmartFactoryBean<?> smartFactoryBean && smartFactoryBean.isEagerInit()) {
   
   
                getBean(beanName);
            }
        }
        else {
   
   
            getBean(beanName);
        }
    }

instantiateSingletonInBackgroundThread方法的作用也就是在通过该Executor线程在后台初始化该Bean,也就是说初始化Bean不使用主线程来创建而是通过创建另一个后台线程来去初始化Bean,也对应了本次PR的提交注释:

Introduce background bootstrapping for individual singleton beans为单个单例引入后台引导

那为什么要创建后台线程来初始化Bean,而不使用主线程呢?

我们翻阅下PR提交的讨论。

在这里插入图片描述

大致意思就是Micrometer对象会窃听GC通知,所以它会等待单例创建锁,而主线程拥有单例创建锁

如果我们使用主线程去创建Micrometer单例的话,Micrometer的创建完成需要主线程释放锁,而主线程释放锁又需要Micrometer先完成创建

这就无限循环了,最终导致了死锁

到这里就解决我们的阅读线索1了,大家还记得不?

阅读线索1:旧代码的死锁是怎么产生的

阅读线索2的答案也显而易见,就是上文提到的通过后台线程来创建Micrometer单例。

阅读线索2:贡献者通过改变什么来解决死锁呢

主线程通过后台线程创建Micrometer单例,因为是异步执行不需要等待创建完成就可以释放锁,而后台线程等待到主线程的单例锁后就可以继续执行流程,避免了死锁的发生。

未完待续。。。

好了,今天的分享就到这🤔。大家能否感受到通过PR这种方式来阅读源码的乐趣呢

创作不易,不妨点赞、收藏、关注支持一下,各位的支持就是我创作的最大动力❤️

相关文章
|
8天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
28 2
|
24天前
|
数据采集 监控 前端开发
二级公立医院绩效考核系统源码,B/S架构,前后端分别基于Spring Boot和Avue框架
医院绩效管理系统通过与HIS系统的无缝对接,实现数据网络化采集、评价结果透明化管理及奖金分配自动化生成。系统涵盖科室和个人绩效考核、医疗质量考核、数据采集、绩效工资核算、收支核算、工作量统计、单项奖惩等功能,提升绩效评估的全面性、准确性和公正性。技术栈采用B/S架构,前后端分别基于Spring Boot和Avue框架。
|
14天前
|
前端开发 Java 开发者
Spring生态学习路径与源码深度探讨
【11月更文挑战第13天】Spring框架作为Java企业级开发中的核心框架,其丰富的生态系统和强大的功能吸引了无数开发者的关注。学习Spring生态不仅仅是掌握Spring Framework本身,更需要深入理解其周边组件和工具,以及源码的底层实现逻辑。本文将从Spring生态的学习路径入手,详细探讨如何系统地学习Spring,并深入解析各个重点的底层实现逻辑。
40 9
|
1月前
|
Java Spring
Spring底层架构源码解析(三)
Spring底层架构源码解析(三)
113 5
|
1月前
|
XML Java 数据格式
Spring底层架构源码解析(二)
Spring底层架构源码解析(二)
|
1月前
|
设计模式 JavaScript Java
Spring 事件监听机制源码
Spring 提供了事件发布订阅机制,广泛应用于项目中。本文介绍了如何通过自定义事件类、订阅类和发布类实现这一机制,并展示了如何监听 SpringBoot 启动过程中的多个事件(如 `ApplicationStartingEvent`、`ApplicationEnvironmentPreparedEvent` 等)。通过掌握这些事件,可以更好地理解 SpringBoot 的启动流程。示例代码展示了从事件发布到接收的完整过程。
|
1月前
|
缓存 Java Spring
源码解读:Spring如何解决构造器注入的循环依赖?
本文详细探讨了Spring框架中的循环依赖问题,包括构造器注入和字段注入两种情况,并重点分析了构造器注入循环依赖的解决方案。文章通过具体示例展示了循环依赖的错误信息及常见场景,提出了三种解决方法:重构代码、使用字段依赖注入以及使用`@Lazy`注解。其中,`@Lazy`注解通过延迟初始化和动态代理机制有效解决了循环依赖问题。作者建议优先使用`@Lazy`注解,并提供了详细的源码解析和调试截图,帮助读者深入理解其实现机制。
37 1
|
1月前
|
存储 开发框架 Java
什么是Spring?什么是IOC?什么是DI?IOC和DI的关系? —— 零基础可无压力学习,带源码
文章详细介绍了Spring、IOC、DI的概念和关系,解释了控制反转(IOC)和依赖注入(DI)的原理,并提供了IOC的代码示例,阐述了Spring框架作为IOC容器的应用。
31 0
什么是Spring?什么是IOC?什么是DI?IOC和DI的关系? —— 零基础可无压力学习,带源码
|
1月前
|
XML Java 数据格式
手动开发-简单的Spring基于注解配置的程序--源码解析
手动开发-简单的Spring基于注解配置的程序--源码解析
47 0
|
1月前
|
XML Java 数据格式
手动开发-简单的Spring基于XML配置的程序--源码解析
手动开发-简单的Spring基于XML配置的程序--源码解析
80 0
下一篇
无影云桌面