Support storage manager with no locks

2013-10-02 14:59:33 +04:00
parent 0c83832f27
commit d7773415bf
2 changed files with 77 additions and 1 deletions
@@ -32,7 +32,22 @@ import java.util.concurrent.locks.ReentrantLock;

 public class LockBasedStorageManager implements StorageManager {

-    protected final Lock lock = new ReentrantLock();
+    public static final StorageManager NO_LOCKS = new LockBasedStorageManager(NoLock.INSTANCE) {
+        @Override
+        public String toString() {
+            return "NO_LOCKS";
+        }
+    };
+
+    protected final Lock lock;
+
+    public LockBasedStorageManager() {
+        this(new ReentrantLock());
+    }
+
+    private LockBasedStorageManager(@NotNull Lock lock) {
+        this.lock = lock;
+    }

    @NotNull
    @Override
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2010-2013 JetBrains s.r.o.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.jetbrains.jet.storage;
+
+import org.jetbrains.annotations.NotNull;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+
+/*package*/ class NoLock implements Lock {
+    public static final Lock INSTANCE = new NoLock();
+
+    private NoLock() {
+    }
+
+    @Override
+    public void lock() {
+        // Do nothing
+    }
+
+    @Override
+    public void unlock() {
+        // Do nothing
+    }
+
+    @Override
+    public void lockInterruptibly() throws InterruptedException {
+        throw new UnsupportedOperationException("Should not be called");
+    }
+
+    @Override
+    public boolean tryLock() {
+        throw new UnsupportedOperationException("Should not be called");
+    }
+
+    @Override
+    public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
+        throw new UnsupportedOperationException("Should not be called");
+    }
+
+    @NotNull
+    @Override
+    public Condition newCondition() {
+        throw new UnsupportedOperationException("Should not be called");
+    }
+}