summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorValerij Fredriksen <valerijf@oath.com>2017-09-20 18:17:38 +0200
committerValerij Fredriksen <valerijf@oath.com>2017-09-20 18:17:38 +0200
commit951171116c4c4449e01fd41f3da2509d9812eb22 (patch)
tree73475473b9bee43b7ae427b5696400f13474d215
parente89a8f9f627a8a1c2d2f0b93aa510d36451b67f8 (diff)
Use lock instead
-rw-r--r--vespajlib/src/main/java/com/yahoo/concurrent/lock/Locking.java11
1 files changed, 3 insertions, 8 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/concurrent/lock/Locking.java b/vespajlib/src/main/java/com/yahoo/concurrent/lock/Locking.java
index cbfadf73a32..4d9f45e959e 100644
--- a/vespajlib/src/main/java/com/yahoo/concurrent/lock/Locking.java
+++ b/vespajlib/src/main/java/com/yahoo/concurrent/lock/Locking.java
@@ -2,7 +2,6 @@ package com.yahoo.concurrent.lock;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
/**
@@ -19,12 +18,8 @@ public class Locking {
* @return the acquired lock
*/
public Lock lock(Class<?> key) {
- try {
- ReentrantLock lock = locks.computeIfAbsent(key, k -> new ReentrantLock(true));
- lock.tryLock(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
- return new Lock(lock);
- } catch (InterruptedException e) {
- throw new RuntimeException("Interrupted while waiting for lock of " + key);
- }
+ ReentrantLock lock = locks.computeIfAbsent(key, k -> new ReentrantLock(true));
+ lock.lock();
+ return new Lock(lock);
}
}