diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/EnhancedCacheConversionService.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/EnhancedCacheConversionService.java index 1cad93b..04f6d4d 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/EnhancedCacheConversionService.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/EnhancedCacheConversionService.java @@ -14,7 +14,6 @@ import org.springframework.core.convert.support.GenericConversionService; import org.springframework.lang.NonNull; import org.springframework.util.ClassUtils; -import org.springframework.util.CollectionUtils; import java.util.Collection; import java.util.HashMap; @@ -83,7 +82,7 @@ static class EnhancedCacheAdapter implements EnhancedCache { @Override public Map multiGet(Collection keys) { - HashMap map = CollectionUtils.newHashMap(keys.size()); + HashMap map = new HashMap<>(keys.size()); keys.forEach(k -> { ValueWrapper valueWrapper = cache.get(k); map.put(k, valueWrapper); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/CaffeineEnhancedCacheConverter.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/CaffeineEnhancedCacheConverter.java index de0fcc1..d2c84de 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/CaffeineEnhancedCacheConverter.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/CaffeineEnhancedCacheConverter.java @@ -6,9 +6,9 @@ import lombok.SneakyThrows; import org.checkerframework.checker.nullness.qual.NonNull; import org.springframework.cache.caffeine.CaffeineCache; -import org.springframework.util.CollectionUtils; import java.util.Collection; +import java.util.HashMap; import java.util.Map; /** @@ -39,7 +39,7 @@ public Map multiGet(Collection keys) { map = cache.getAllPresent(keys); } - Map newMap = CollectionUtils.newHashMap(keys.size()); + Map newMap = new HashMap<>(keys.size()); map.forEach((key, value) -> newMap.put(key, toValueWrapper(value))); return newMap; @@ -47,7 +47,7 @@ public Map multiGet(Collection keys) { @Override public void multiPut(Map map) { - Map newMap = CollectionUtils.newHashMap(map.size()); + Map newMap = new HashMap<>(map.size()); map.forEach((key, value) -> newMap.put(key, toStoreValue(value))); getNativeCache().putAll(newMap); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/ConcurrentMapEnhancedCacheConverter.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/ConcurrentMapEnhancedCacheConverter.java index b9e56de..57982db 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/ConcurrentMapEnhancedCacheConverter.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/ConcurrentMapEnhancedCacheConverter.java @@ -5,10 +5,10 @@ import org.springframework.cache.concurrent.ConcurrentMapCache; import org.springframework.core.serializer.support.SerializationDelegate; import org.springframework.lang.Nullable; -import org.springframework.util.CollectionUtils; import java.lang.reflect.Field; import java.util.Collection; +import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentMap; @@ -51,7 +51,7 @@ protected ConcurrentMapEnhancedCache(String name, ConcurrentMap @Override public Map multiGet(Collection keys) { - Map map = CollectionUtils.newHashMap(keys.size()); + Map map = new HashMap<>(keys.size()); keys.forEach(key -> { ValueWrapper valueWrapper = this.get(key); @@ -64,7 +64,7 @@ public Map multiGet(Collection keys) { @Override @SneakyThrows public void multiPut(Map map) { - Map newMap = CollectionUtils.newHashMap(map.size()); + Map newMap = new HashMap<>(map.size()); map.forEach((k, v) -> newMap.put(k, toStoreValue(v))); ConcurrentMap store = getNativeCache(); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/EhcacheEnhancedCacheConverter.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/EhcacheEnhancedCacheConverter.java index 78c1374..2ee2693 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/EhcacheEnhancedCacheConverter.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/EhcacheEnhancedCacheConverter.java @@ -7,10 +7,10 @@ import org.springframework.cache.ehcache.EhCacheCache; import org.springframework.cache.support.SimpleValueWrapper; import org.springframework.lang.Nullable; -import org.springframework.util.CollectionUtils; import java.util.ArrayList; import java.util.Collection; +import java.util.HashMap; import java.util.Map; /** @@ -34,7 +34,7 @@ public EhcacheEnhancedCache(Ehcache ehcache) { public Map multiGet(Collection keys) { Map map = getNativeCache().getAll(keys); - Map newMap = CollectionUtils.newHashMap(keys.size()); + Map newMap = new HashMap<>(keys.size()); map.forEach((key, value) -> newMap.put(key, toValueWrapper(value))); return newMap; diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/RedisEnhancedCacheConverter.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/RedisEnhancedCacheConverter.java index 71751c0..f6dbeb2 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/RedisEnhancedCacheConverter.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/convert/converter/RedisEnhancedCacheConverter.java @@ -9,7 +9,6 @@ import org.springframework.data.redis.connection.RedisStringCommands; import org.springframework.data.redis.core.types.Expiration; import org.springframework.lang.Nullable; -import org.springframework.util.CollectionUtils; import java.lang.reflect.Method; import java.time.Duration; @@ -61,7 +60,7 @@ public Map multiGet(Collection keys) { throw new IllegalStateException(); } - HashMap map = CollectionUtils.newHashMap(keyArr.length); + HashMap map = new HashMap<>(keyArr.length); for (int i = 0, length = keyArr.length; i < length; i++) { byte[] value = values.get(i); ValueWrapper valueWrapper = toValueWrapper(value == null ? null : deserializeCacheValue(value)); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/AbstractCacheAsMultiOperation.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/AbstractCacheAsMultiOperation.java index ba0e8dd..bde745f 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/AbstractCacheAsMultiOperation.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/AbstractCacheAsMultiOperation.java @@ -156,7 +156,7 @@ private static class ListReturnTypeMaker implements ReturnTypeMaker> { if (parameterDetail.isStrictNull()) { return Collections.emptyMap(); } - Map map = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + Map map = new HashMap<>(subCacheAsMultiArg.size()); for (Object o : subCacheAsMultiArg) { map.put(o, null); } @@ -167,14 +167,14 @@ private static class ListReturnTypeMaker implements ReturnTypeMaker> { if (invokeValues.size() != subCacheAsMultiArg.size()) { throw new IllegalStateException("The size of return list is not equal to the size of parameter list"); } - Map map = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + Map map = new HashMap<>(subCacheAsMultiArg.size()); Iterator iterator = invokeValues.iterator(); subCacheAsMultiArg.forEach((argItem) -> { map.put(argItem, iterator.next()); }); return map; } - Map map = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + Map map = new HashMap<>(subCacheAsMultiArg.size()); invokeValues.forEach(i -> { SimpleEvaluationContext context = CONTEXT_BUILDER.withRootObject(i).build(); map.put(parameterDetail.getAsElementFieldExpression().getValue(context), i); @@ -217,7 +217,7 @@ private static class MapReturnTypeMaker implements ReturnTypeMaker> { if (parameterDetail.isStrictNull()) { return Collections.emptyMap(); } - Map map = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + Map map = new HashMap<>(subCacheAsMultiArg.size()); for (Object o : subCacheAsMultiArg) { map.put(o, null); } @@ -228,7 +228,7 @@ private static class MapReturnTypeMaker implements ReturnTypeMaker> { return invokeValues; } - Map map = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + Map map = new HashMap<>(subCacheAsMultiArg.size()); for (Object o : subCacheAsMultiArg) { map.put(o, invokeValues.get(o)); } diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/EnhancedCachingInterceptor.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/EnhancedCachingInterceptor.java index 3d77ce2..83fde27 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/EnhancedCachingInterceptor.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/cache/interceptor/EnhancedCachingInterceptor.java @@ -214,7 +214,7 @@ private void performCacheEvict( CacheAsMultiOperation multiOperation = firstContext.getMultiOperation(); Collection cacheAsMultiArg = contexts.getCacheAsMultiArg(); assert cacheAsMultiArg != null; - Map argValueMap = CollectionUtils.newHashMap(cacheAsMultiArg.size()); + Map argValueMap = new HashMap<>(cacheAsMultiArg.size()); Collection missCacheAsMultiArg = cacheAsMultiArg; @@ -431,7 +431,7 @@ private Collection generateKeys(CacheAsMultiOperationContext context, private Map generateArgKeyMap(CacheAsMultiOperationContext context, Collection subCacheAsMultiArg) { - HashMap argKeyMap = CollectionUtils.newHashMap(subCacheAsMultiArg.size()); + HashMap argKeyMap = new HashMap<>(subCacheAsMultiArg.size()); for (Object argItem : subCacheAsMultiArg) { argKeyMap.put(argItem, context.generateKey(argItem, null)); } @@ -442,7 +442,7 @@ private Map generateArgKeyMap(CacheAsMultiOperationContext conte private Map generateKeyValueMap(CacheAsMultiOperationContext context, Collection subCacheAsMultiArg, Map argValueMap) { - HashMap keyValueMap = CollectionUtils.newHashMap(argValueMap.size()); + HashMap keyValueMap = new HashMap<>(argValueMap.size()); for (Object argItem : subCacheAsMultiArg) { Object value = argValueMap.get(argItem); keyValueMap.put(context.generateKey(argItem, value), value); @@ -604,8 +604,8 @@ public CacheAsMultiOperationContext(CacheAsMultiOperation multiOperation, Cac this.multiOperation = multiOperation; this.superArgs = super.getArgs(); this.cacheAsMultiArg = (Collection) args[multiOperation.getCacheAsMultiParameterPosition()]; - this.isConditionPassingCache = CollectionUtils.newHashMap(cacheAsMultiArg.size()); - this.keyCache = CollectionUtils.newHashMap(cacheAsMultiArg.size()); + this.isConditionPassingCache = new HashMap<>(cacheAsMultiArg.size()); + this.keyCache = new HashMap<>(cacheAsMultiArg.size()); } @Override diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/EnhancedJCacheCache.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/EnhancedJCacheCache.java index ee1da09..05053a3 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/EnhancedJCacheCache.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/EnhancedJCacheCache.java @@ -2,10 +2,10 @@ import io.github.ms100.cacheasmulti.cache.EnhancedCache; import org.springframework.cache.jcache.JCacheCache; -import org.springframework.util.CollectionUtils; import javax.cache.Cache; import java.util.Collection; +import java.util.HashMap; import java.util.HashSet; import java.util.Map; @@ -28,7 +28,7 @@ public EnhancedJCacheCache(Cache jcache, boolean allowNullValues public Map multiGet(Collection keys) { Map map = getNativeCache().getAll(new HashSet<>(keys)); - Map newMap = CollectionUtils.newHashMap(keys.size()); + Map newMap = new HashMap<>(keys.size()); map.forEach((key, value) -> newMap.put(key, toValueWrapper(value))); return newMap; @@ -36,7 +36,7 @@ public Map multiGet(Collection keys) { @Override public void multiPut(Map map) { - Map newMap = CollectionUtils.newHashMap(map.size()); + Map newMap = new HashMap<>(map.size()); map.forEach((key, value) -> newMap.put(key, toStoreValue(value))); getNativeCache().putAll(newMap); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheAsMultiOperationContext.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheAsMultiOperationContext.java index c51870e..5ce0746 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheAsMultiOperationContext.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheAsMultiOperationContext.java @@ -8,7 +8,6 @@ import org.springframework.cache.jcache.interceptor.JCacheOperation; import org.springframework.cache.jcache.interceptor.SimpleExceptionCacheResolver; import org.springframework.lang.Nullable; -import org.springframework.util.CollectionUtils; import javax.cache.annotation.CacheInvocationContext; import javax.cache.annotation.CacheInvocationParameter; @@ -16,6 +15,7 @@ import java.lang.annotation.Annotation; import java.lang.reflect.Method; import java.util.Collection; +import java.util.HashMap; import java.util.Map; import java.util.Set; @@ -64,7 +64,7 @@ public CacheAsMultiOperationContext(O multiOperation, Object target, Object[] ar } else if (cacheAsMultiArg instanceof Map) { size = ((Map) cacheAsMultiArg).size(); } - this.keyCache = CollectionUtils.newHashMap(size); + this.keyCache = new HashMap<>(size); } @Override diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CachePutAsMultiInterceptor.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CachePutAsMultiInterceptor.java index c1e4772..82501de 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CachePutAsMultiInterceptor.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CachePutAsMultiInterceptor.java @@ -8,6 +8,7 @@ import org.springframework.util.CollectionUtils; import javax.cache.annotation.CachePut; +import java.util.HashMap; import java.util.Map; /** @@ -52,7 +53,7 @@ protected void cacheValues(CacheAsMultiOperationContext keyValueMap = CollectionUtils.newHashMap(cacheAsMultiArg.size()); + Map keyValueMap = new HashMap<>(cacheAsMultiArg.size()); cacheAsMultiArg.forEach((argItem, value) -> keyValueMap.put(context.generateKey(argItem), value)); EnhancedCache cache = resolveCache(context); diff --git a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheResultAsMultiInterceptor.java b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheResultAsMultiInterceptor.java index d0c4cab..0b1c307 100644 --- a/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheResultAsMultiInterceptor.java +++ b/cache-as-multi/src/main/java/io/github/ms100/cacheasmulti/jcache/interceptor/CacheResultAsMultiInterceptor.java @@ -12,10 +12,7 @@ import org.springframework.util.CollectionUtils; import javax.cache.annotation.CacheResult; -import java.util.ArrayList; -import java.util.Collection; -import java.util.Map; -import java.util.Objects; +import java.util.*; import java.util.stream.Collectors; /** @@ -40,7 +37,7 @@ public Object invoke(CacheAsMultiOperationContext argValueMap = CollectionUtils.newHashMap(cacheAsMultiArg.size()); + Map argValueMap = new HashMap<>(cacheAsMultiArg.size()); Collection missCacheAsMultiArg = findInCache(context, cacheAsMultiArg, argValueMap); @@ -63,7 +60,7 @@ public Object invoke(CacheAsMultiOperationContext findInCache(CacheAsMultiOperationContext context, Collection cacheAsMultiArg, Map argValueMap) { - Map argKeyMap = CollectionUtils.newHashMap(cacheAsMultiArg.size()); + Map argKeyMap = new HashMap<>(cacheAsMultiArg.size()); cacheAsMultiArg.forEach(argItem -> argKeyMap.put(argItem, context.generateKey(argItem))); if (log.isTraceEnabled()) { log.trace("Find keys " + argKeyMap.values() + " for operation " + context.getOperation()); @@ -113,7 +110,7 @@ private Object invokeWithMissCacheAsMultiArg(CacheAsMultiOperationContext missKeyValueMap = CollectionUtils.newHashMap(missCacheAsMultiArg.size()); + Map missKeyValueMap = new HashMap<>(missCacheAsMultiArg.size()); missArgValueMap.forEach((argItem, value) -> missKeyValueMap.put(context.generateKey(argItem), value)); EnhancedCache cache = resolveCache(context); // 缓存数据