Skip to content

Commit

Permalink
Avoid full synchronization in refreshable getBeanFactory() implementa…
Browse files Browse the repository at this point in the history
…tion

Closes gh-25081
  • Loading branch information
jhoeller committed May 18, 2020
1 parent 35f3277 commit 06cfd80
Showing 1 changed file with 16 additions and 26 deletions.
@@ -1,5 +1,5 @@
/*
* Copyright 2002-2018 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.
Expand Down Expand Up @@ -72,10 +72,7 @@ public abstract class AbstractRefreshableApplicationContext extends AbstractAppl

/** Bean factory for this context. */
@Nullable
private DefaultListableBeanFactory beanFactory;

/** Synchronization monitor for the internal BeanFactory. */
private final Object beanFactoryMonitor = new Object();
private volatile DefaultListableBeanFactory beanFactory;


/**
Expand Down Expand Up @@ -131,9 +128,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);
Expand All @@ -142,21 +137,19 @@ 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) {
if (this.beanFactory != null) {
this.beanFactory.setSerializationId(null);
this.beanFactory = null;
}
DefaultListableBeanFactory beanFactory = this.beanFactory;
if (beanFactory != null) {
beanFactory.setSerializationId(null);
this.beanFactory = null;
}
}

Expand All @@ -165,20 +158,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;
}

/**
Expand Down

0 comments on commit 06cfd80

Please sign in to comment.