Optimize cache usage in DefaultConversionService and fix race conditi…

…on (#10143) * Optimize cache usage in DefaultConversionService and fix race condition (#10091) * Fix HttpGetSpec
micronaut-projects · Jan 9, 2024 · b611160 · b611160
1 parent 2e5802e
commit b611160
Showing 1 changed file with 15 additions and 40 deletions.
diff --git a/core/src/main/java/io/micronaut/core/convert/DefaultConversionService.java b/core/src/main/java/io/micronaut/core/convert/DefaultConversionService.java
@@ -125,55 +125,28 @@ public <T> Optional<T> convert(Object object, Class<T> targetType, ConversionCon
             ConvertiblePair pair = new ConvertiblePair(sourceType, targetType, formattingAnnotation);
             TypeConverter typeConverter = converterCache.get(pair);
             if (typeConverter == null) {
-                typeConverter = findTypeConverter(sourceType, targetType, formattingAnnotation);
-                if (typeConverter == null) {
-                    return Optional.empty();
-                } else {
-                    converterCache.put(pair, typeConverter);
-                    if (typeConverter == UNCONVERTIBLE) {
-                        return Optional.empty();
-                    } else {
-                        return typeConverter.convert(object, targetType, context);
-                    }
-                }
-            } else if (typeConverter != UNCONVERTIBLE) {
-                return typeConverter.convert(object, targetType, context);
+                typeConverter = findTypeConverter(pair.source, pair.target, pair.formattingAnnotation);
+                converterCache.put(pair, typeConverter);
             }
+           return typeConverter.convert(object, targetType, context);
         } else {
             ConvertiblePair pair = new ConvertiblePair(sourceType, targetType, null);
             TypeConverter typeConverter = converterCache.get(pair);
             if (typeConverter == null) {
-                typeConverter = findTypeConverter(sourceType, targetType, null);
-                if (typeConverter == null) {
-                    converterCache.put(pair, UNCONVERTIBLE);
-                    return Optional.empty();
-                } else {
-                    converterCache.put(pair, typeConverter);
-                    if (typeConverter == UNCONVERTIBLE) {
-                        return Optional.empty();
-                    } else {
-                        return typeConverter.convert(object, targetType, context);
-                    }
-                }
-            } else if (typeConverter != UNCONVERTIBLE) {
-                return typeConverter.convert(object, targetType, context);
+                typeConverter = findTypeConverter(pair.source, pair.target, pair.formattingAnnotation);
+                converterCache.put(pair, typeConverter);
             }
+            return typeConverter.convert(object, targetType, context);
         }
-
-        return Optional.empty();
     }
 
     @Override
     public <S, T> boolean canConvert(Class<S> sourceType, Class<T> targetType) {
         ConvertiblePair pair = new ConvertiblePair(sourceType, targetType, null);
         TypeConverter typeConverter = converterCache.get(pair);
         if (typeConverter == null) {
-            typeConverter = findTypeConverter(sourceType, targetType, null);
-            if (typeConverter != null) {
-                converterCache.put(pair, typeConverter);
-                return typeConverter != UNCONVERTIBLE;
-            }
-            return false;
+            typeConverter = findTypeConverter(pair.source, pair.target, pair.formattingAnnotation);
+            converterCache.put(pair, typeConverter);
         }
         return typeConverter != UNCONVERTIBLE;
     }
@@ -202,7 +175,7 @@ public <S, T> DefaultConversionService addConverter(Class<S> sourceType, Class<T
      * @since 3.5.3
      */
     @Internal
-    public void reset() {
+    public synchronized void reset() {
         typeConverters.clear();
         converterCache.clear();
         registerDefaultConverters();
@@ -212,7 +185,7 @@ public void reset() {
      * Default Converters.
      */
     @SuppressWarnings({"OptionalIsPresent", "unchecked"})
-    protected void registerDefaultConverters() {
+    protected synchronized void registerDefaultConverters() {
         // primitive array to wrapper array
         @SuppressWarnings("rawtypes")
         Function primitiveArrayToWrapperArray = ArrayUtils::toWrapperArray;
@@ -974,8 +947,8 @@ protected void registerDefaultConverters() {
      * @param <T> Generic type
      * @return type converter
      */
-    protected <T> TypeConverter findTypeConverter(Class<?> sourceType, Class<T> targetType, String formattingAnnotation) {
-        TypeConverter typeConverter = UNCONVERTIBLE;
+    protected synchronized  <T> TypeConverter findTypeConverter(Class<?> sourceType, Class<T> targetType, String formattingAnnotation) {
+        TypeConverter typeConverter = null;
         List<Class> sourceHierarchy = ClassUtils.resolveHierarchy(sourceType);
         List<Class> targetHierarchy = ClassUtils.resolveHierarchy(targetType);
         for (Class sourceSuperType : sourceHierarchy) {
@@ -988,6 +961,7 @@ protected <T> TypeConverter findTypeConverter(Class<?> sourceType, Class<T> targ
                 }
             }
         }
+
         boolean hasFormatting = formattingAnnotation != null;
         if (hasFormatting) {
             for (Class sourceSuperType : sourceHierarchy) {
@@ -1001,7 +975,8 @@ protected <T> TypeConverter findTypeConverter(Class<?> sourceType, Class<T> targ
                 }
             }
         }
-        return typeConverter;
+
+        return UNCONVERTIBLE;
     }
 
     private SimpleDateFormat resolveFormat(ConversionContext context) {