cache

added synchronized blocks based on received key

6/30/2019 11:20:00 PM

Rômulo Manciola Meloca

Commit: 4cab90e

Tree: d6d4ed2

Parents: c0d8487

Changes

src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java 24(+14 -10)

Details

src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java 24(+14 -10)

diff --git a/src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java b/src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java
index 8336a09..044ba54 100644
--- a/src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java
+++ b/src/main/java/br/ufrgs/inf/prosoft/cache/Cache.java
@@ -24,22 +24,26 @@ public interface Cache<K, V> {
     public void invalidate(K key);
 
     public default V computeIfAbsent(K key, Supplier<V> supplier, long timeToLive) {
-        V get = get(key);
-        if (get != null) {
+        synchronized (key) {
+            V get = get(key);
+            if (get != null) {
+                return get;
+            }
+            get = supplier.get();
+            put(key, get, timeToLive);
             return get;
         }
-        get = supplier.get();
-        put(key, get, timeToLive);
-        return get;
     }
 
     public default V computeIfAbsent(K key, Supplier<V> supplier) {
-        V get = get(key);
-        if (get != null) {
+        synchronized (key) {
+            V get = get(key);
+            if (get != null) {
+                return get;
+            }
+            get = supplier.get();
+            put(key, get);
             return get;
         }
-        get = supplier.get();
-        put(key, get);
-        return get;
     }
 }