From 31cda09c93ce1630dc6f77a9611bb083f9aadc57 Mon Sep 17 00:00:00 2001 From: Juergen Hoeller Date: Wed, 10 Jun 2020 12:15:07 +0200 Subject: [PATCH] Avoid full synchronization in refreshable getBeanFactory() implementation Closes gh-25219 --- ...AbstractRefreshableApplicationContext.java | 37 ++++++++----------- 1 file changed, 15 insertions(+), 22 deletions(-) diff --git a/spring-context/src/main/java/org/springframework/context/support/AbstractRefreshableApplicationContext.java b/spring-context/src/main/java/org/springframework/context/support/AbstractRefreshableApplicationContext.java index d14787bcbb91..bd41167403fd 100644 --- a/spring-context/src/main/java/org/springframework/context/support/AbstractRefreshableApplicationContext.java +++ b/spring-context/src/main/java/org/springframework/context/support/AbstractRefreshableApplicationContext.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2013 the original author or authors. + * Copyright 2002-2020 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -68,10 +68,7 @@ public abstract class AbstractRefreshableApplicationContext extends AbstractAppl private Boolean allowCircularReferences; /** Bean factory for this context */ - private DefaultListableBeanFactory beanFactory; - - /** Synchronization monitor for the internal BeanFactory */ - private final Object beanFactoryMonitor = new Object(); + private volatile DefaultListableBeanFactory beanFactory; /** @@ -127,9 +124,7 @@ protected final void refreshBeanFactory() throws BeansException { beanFactory.setSerializationId(getId()); customizeBeanFactory(beanFactory); loadBeanDefinitions(beanFactory); - synchronized (this.beanFactoryMonitor) { - this.beanFactory = beanFactory; - } + this.beanFactory = beanFactory; } catch (IOException ex) { throw new ApplicationContextException("I/O error parsing bean definition source for " + getDisplayName(), ex); @@ -138,17 +133,18 @@ protected final void refreshBeanFactory() throws BeansException { @Override protected void cancelRefresh(BeansException ex) { - synchronized (this.beanFactoryMonitor) { - if (this.beanFactory != null) - this.beanFactory.setSerializationId(null); + DefaultListableBeanFactory beanFactory = this.beanFactory; + if (beanFactory != null) { + beanFactory.setSerializationId(null); } super.cancelRefresh(ex); } @Override protected final void closeBeanFactory() { - synchronized (this.beanFactoryMonitor) { - this.beanFactory.setSerializationId(null); + DefaultListableBeanFactory beanFactory = this.beanFactory; + if (beanFactory != null) { + beanFactory.setSerializationId(null); this.beanFactory = null; } } @@ -158,20 +154,17 @@ protected final void closeBeanFactory() { * i.e. has been refreshed at least once and not been closed yet. */ protected final boolean hasBeanFactory() { - synchronized (this.beanFactoryMonitor) { - return (this.beanFactory != null); - } + return (this.beanFactory != null); } @Override public final ConfigurableListableBeanFactory getBeanFactory() { - synchronized (this.beanFactoryMonitor) { - if (this.beanFactory == null) { - throw new IllegalStateException("BeanFactory not initialized or already closed - " + - "call 'refresh' before accessing beans via the ApplicationContext"); - } - return this.beanFactory; + DefaultListableBeanFactory beanFactory = this.beanFactory; + if (beanFactory == null) { + throw new IllegalStateException("BeanFactory not initialized or already closed - " + + "call 'refresh' before accessing beans via the ApplicationContext"); } + return beanFactory; } /**