Use ReentrantLock instead of intrinsic locks in LockBasedStorageManager

compiler/frontend/src/org/jetbrains/jet/lang/resolve/lazy/storage/LockBasedLazyResolveStorageManager.java

@@ -29,6 +29,7 @@ import org.jetbrains.jet.util.slicedmap.ReadOnlySlice;
 import org.jetbrains.jet.util.slicedmap.WritableSlice;
 
 import java.util.Collection;
+import java.util.concurrent.locks.Lock;
 
 public class LockBasedLazyResolveStorageManager extends LockBasedStorageManager implements LazyResolveStorageManager {
     @NotNull
@@ -40,10 +41,10 @@ public class LockBasedLazyResolveStorageManager extends LockBasedStorageManager
     }
 
     private static class LockProtectedContext implements BindingContext {
-        private final Object lock;
+        private final Lock lock;
         private final BindingContext context;
 
-        private LockProtectedContext(Object lock, BindingContext context) {
+        private LockProtectedContext(Lock lock, BindingContext context) {
             this.lock = lock;
             this.context = context;
         }
@@ -51,43 +52,59 @@ public class LockBasedLazyResolveStorageManager extends LockBasedStorageManager
         @NotNull
         @Override
         public Diagnostics getDiagnostics() {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return context.getDiagnostics();
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @Nullable
         @Override
         public <K, V> V get(ReadOnlySlice<K, V> slice, K key) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return context.get(slice, key);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @NotNull
         @Override
         public <K, V> Collection<K> getKeys(WritableSlice<K, V> slice) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return context.getKeys(slice);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @NotNull
         @Override
         @TestOnly
         public <K, V> ImmutableMap<K, V> getSliceContents(@NotNull ReadOnlySlice<K, V> slice) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return context.getSliceContents(slice);
             }
+            finally {
+                lock.unlock();
+            }
         }
     }
 
     private static class LockProtectedTrace implements BindingTrace {
-        private final Object lock;
+        private final Lock lock;
         private final BindingTrace trace;
         private final BindingContext context;
 
-        public LockProtectedTrace(@NotNull Object lock, @NotNull BindingTrace trace) {
+        public LockProtectedTrace(@NotNull Lock lock, @NotNull BindingTrace trace) {
             this.lock = lock;
             this.trace = trace;
             this.context = new LockProtectedContext(lock, trace.getBindingContext());
@@ -100,39 +117,59 @@ public class LockBasedLazyResolveStorageManager extends LockBasedStorageManager
 
         @Override
         public <K, V> void record(WritableSlice<K, V> slice, K key, V value) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 trace.record(slice, key, value);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @Override
         public <K> void record(WritableSlice<K, Boolean> slice, K key) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 trace.record(slice, key);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @Override
         @Nullable
         public <K, V> V get(ReadOnlySlice<K, V> slice, K key) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return trace.get(slice, key);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @Override
         @NotNull
         public <K, V> Collection<K> getKeys(WritableSlice<K, V> slice) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 return trace.getKeys(slice);
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         @Override
         public void report(@NotNull Diagnostic diagnostic) {
-            synchronized (lock) {
+            lock.lock();
+            try {
                 trace.report(diagnostic);
             }
+            finally {
+                lock.unlock();
+            }
         }
     }
 }

core/util.runtime/src/org/jetbrains/jet/storage/LockBasedStorageManager.java

@@ -27,15 +27,12 @@ import org.jetbrains.jet.utils.WrappedValues;
 
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
 
 public class LockBasedStorageManager implements StorageManager {
 
-    protected final Object lock = new Object() {
+    protected final Lock lock = new ReentrantLock();
-        @Override
-        public String toString() {
-            return "LockBasedStorageManager centralized lock";
-        }
-    };
 
     @NotNull
     @Override
@@ -134,9 +131,13 @@ public class LockBasedStorageManager implements StorageManager {
 
     @Override
     public <T> T compute(@NotNull Computable<T> computable) {
-        synchronized (lock) {
+        lock.lock();
+        try {
             return computable.compute();
         }
+        finally {
+            lock.unlock();
+        }
     }
 
     private static class LockBasedLazyValue<T> implements NullableLazyValue<T> {
@@ -144,13 +145,13 @@ public class LockBasedStorageManager implements StorageManager {
         private static final Object NOT_COMPUTED = new Object();
         private static final Object COMPUTING = new Object();
 
-        private final Object lock;
+        private final Lock lock;
         private final Computable<T> computable;
 
         @Nullable
         private volatile Object value = NOT_COMPUTED;
 
-        public LockBasedLazyValue(@NotNull Object lock, @NotNull Computable<T> computable) {
+        public LockBasedLazyValue(@NotNull Lock lock, @NotNull Computable<T> computable) {
             this.lock = lock;
             this.computable = computable;
         }
@@ -165,7 +166,8 @@ public class LockBasedStorageManager implements StorageManager {
             Object _value = value;
             if (_value != NOT_COMPUTED && _value != COMPUTING) return WrappedValues.unescapeThrowable(_value);
 
-            synchronized (lock) {
+            lock.lock();
+            try {
                 _value = value;
                 if (_value == COMPUTING) {
                     Object result = recursionDetected();
@@ -188,6 +190,9 @@ public class LockBasedStorageManager implements StorageManager {
                     throw ExceptionUtils.rethrow(throwable);
                 }
             }
+            finally {
+                lock.unlock();
+            }
         }
 
         /**
@@ -206,7 +211,7 @@ public class LockBasedStorageManager implements StorageManager {
 
     private static class LockBasedNotNullLazyValue<T> extends LockBasedLazyValue<T> implements NotNullLazyValue<T> {
 
-        public LockBasedNotNullLazyValue(@NotNull Object lock, @NotNull Computable<T> computable) {
+        public LockBasedNotNullLazyValue(@NotNull Lock lock, @NotNull Computable<T> computable) {
             super(lock, computable);
         }
 
@@ -220,11 +225,11 @@ public class LockBasedStorageManager implements StorageManager {
     }
 
     private static class MapBasedMemoizedFunction<K, V> implements MemoizedFunctionToNullable<K, V> {
-        private final Object lock;
+        private final Lock lock;
         private final ConcurrentMap<K, Object> cache;
         private final Function<K, V> compute;
 
-        public MapBasedMemoizedFunction(@NotNull Object lock, @NotNull ConcurrentMap<K, Object> map, @NotNull Function<K, V> compute) {
+        public MapBasedMemoizedFunction(@NotNull Lock lock, @NotNull ConcurrentMap<K, Object> map, @NotNull Function<K, V> compute) {
             this.lock = lock;
             this.cache = map;
             this.compute = compute;
@@ -236,7 +241,8 @@ public class LockBasedStorageManager implements StorageManager {
             Object value = cache.get(input);
             if (value != null) return WrappedValues.unescapeExceptionOrNull(value);
 
-            synchronized (lock) {
+            lock.lock();
+            try {
                 value = cache.get(input);
                 if (value != null) return WrappedValues.unescapeExceptionOrNull(value);
 
@@ -254,13 +260,16 @@ public class LockBasedStorageManager implements StorageManager {
                     throw ExceptionUtils.rethrow(throwable);
                 }
             }
+            finally {
+                lock.unlock();
+            }
         }
     }
 
     private static class MapBasedMemoizedFunctionToNotNull<K, V> extends MapBasedMemoizedFunction<K, V> implements MemoizedFunctionToNotNull<K, V> {
 
         public MapBasedMemoizedFunctionToNotNull(
-                @NotNull Object lock,
+                @NotNull Lock lock,
                 @NotNull ConcurrentMap<K, Object> map,
                 @NotNull Function<K, V> compute
         ) {