SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use concurrent hash map in function catalog

Browse Source
This commit is contained in:
Dave Syer
2018-04-24 10:23:22 +01:00
parent 2df5dcc992
commit 57c05970e5
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfiguration.java
View File

@@ -32,6 +32,7 @@ import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Consumer;
import java.util.function.Function;
import java.util.function.Supplier;
@@ -172,11 +173,11 @@ public class ContextFunctionCatalogAutoConfiguration {
@Component
protected static class ContextFunctionRegistry {
private Map<String, Object> suppliers = new HashMap<>();
private Map<String, Object> suppliers = new ConcurrentHashMap<>();
private Map<String, Object> functions = new HashMap<>();
private Map<String, Object> functions = new ConcurrentHashMap<>();
private Map<String, Object> consumers = new HashMap<>();
private Map<String, Object> consumers = new ConcurrentHashMap<>();
@Autowired(required = false)
private ApplicationEventPublisher publisher;
@@ -184,16 +185,16 @@ public class ContextFunctionCatalogAutoConfiguration {
@Autowired
private ConfigurableListableBeanFactory registry;
private Map<Object, String> names = new HashMap<>();
private Map<Object, String> names = new ConcurrentHashMap<>();
private Map<String, FunctionType> types = new HashMap<>();
private Map<String, FunctionType> types = new ConcurrentHashMap<>();
public Set<String> getSuppliers() {
return this.suppliers.keySet();
}
public FunctionRegistration<?> getRegistration(Object function) {
if (!names.containsKey(function)) {
if (function == null || !names.containsKey(function)) {
return null;
}
return new FunctionRegistration<>(function).name(names.get(function))