Skip to content

Commit

Permalink
Fixes #3997 : Make SupplierFactoryBridge thread-safe.
Browse files Browse the repository at this point in the history
Signed-off-by: Francois JACQUES <fjacques@murex.com>
  • Loading branch information
hypnoce authored and JACQUES Francois committed Aug 12, 2019
1 parent 01cb903 commit 6d35782
Showing 1 changed file with 8 additions and 8 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright (c) 2017, 2018 Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2017, 2019 Oracle and/or its affiliates. All rights reserved.
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License v. 2.0, which is available at
Expand All @@ -18,6 +18,7 @@

import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.Collections;
import java.util.IdentityHashMap;
import java.util.Map;
import java.util.function.Supplier;
Expand All @@ -42,15 +43,15 @@
*/
public class SupplierFactoryBridge<T> implements Factory<T> {

private ServiceLocator locator;
private ParameterizedType beanType;
private String beanName;
private boolean disposable;
private final ServiceLocator locator;
private final ParameterizedType beanType;
private final String beanName;
private final boolean disposable;

// This bridge can create multiple instances using the method 'provide' therefore must map created suppliers because of
// 'dispose' invocation later on.
// TODO: Key as a WeakReference - prevent objects in scope which never dispose the objects such as PerLookup.
private Map<Object, DisposableSupplier<T>> disposableSuppliers = new IdentityHashMap<>();
private Map<Object, DisposableSupplier<T>> disposableSuppliers = Collections.synchronizedMap(new IdentityHashMap<>());

/**
* Constructor for a new bridge.
Expand Down Expand Up @@ -85,9 +86,8 @@ public T provide() {
@Override
public void dispose(T instance) {
if (disposable) {
DisposableSupplier<T> disposableSupplier = disposableSuppliers.get(instance);
DisposableSupplier<T> disposableSupplier = disposableSuppliers.remove(instance);
disposableSupplier.dispose(instance);
disposableSuppliers.remove(instance);
}
}
}

0 comments on commit 6d35782

Please sign in to comment.