optimise penetration protect

areyouok · areyouok · commit ae4e480b55f7 · 2019-11-01T01:03:11.000+08:00
diff --git a/jetcache-core/src/main/java/com/alicp/jetcache/AbstractCache.java b/jetcache-core/src/main/java/com/alicp/jetcache/AbstractCache.java
@@ -164,9 +164,9 @@ static <K, V> V computeIfAbsentImpl(K key, Function<K, V> loader, boolean cacheN
             Consumer<V> cacheUpdater = (loadedValue) -> {
                 if(needUpdate(loadedValue, cacheNullWhenLoaderReturnNull, newLoader)) {
                     if (timeUnit != null) {
-                        cache.PUT(key, loadedValue, expireAfterWrite, timeUnit);
+                        cache.PUT(key, loadedValue, expireAfterWrite, timeUnit).waitForResult();
                     } else {
-                        cache.put(key, loadedValue);
+                        cache.PUT(key, loadedValue).waitForResult();
                     }
                 }
             };

Original file line number	Diff line number	Diff line change
`@@ -164,9 +164,9 @@ static <K, V> V computeIfAbsentImpl(K key, Function<K, V> loader, boolean cacheN`
`164`	`164`	`Consumer<V> cacheUpdater = (loadedValue) -> {`
`165`	`165`	`if(needUpdate(loadedValue, cacheNullWhenLoaderReturnNull, newLoader)) {`
`166`	`166`	`if (timeUnit != null) {`
`167`		`- cache.PUT(key, loadedValue, expireAfterWrite, timeUnit);`
	`167`	`+ cache.PUT(key, loadedValue, expireAfterWrite, timeUnit).waitForResult();`
`168`	`168`	`} else {`
`169`		`- cache.put(key, loadedValue);`
	`169`	`+ cache.PUT(key, loadedValue).waitForResult();`
`170`	`170`	`}`
`171`	`171`	`}`
`172`	`172`	`};`