summaryrefslogtreecommitdiffstats
path: root/vespajlib
diff options
context:
space:
mode:
authorValerij Fredriksen <valerijf@oath.com>2017-09-26 10:34:11 +0200
committerValerij Fredriksen <valerijf@oath.com>2017-09-26 10:34:11 +0200
commit843dd99fdd5dcc1154d5693d0058e54b809da60c (patch)
tree3045718b4c907d443c0af5ba2dbbab3b84057290 /vespajlib
parenteba935248e99605a42eaccbdebfd53dea7e983ef (diff)
Use String as lock key
Diffstat (limited to 'vespajlib')
-rw-r--r--vespajlib/src/main/java/com/yahoo/concurrent/classlock/ClassLocking.java10
1 files changed, 5 insertions, 5 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/concurrent/classlock/ClassLocking.java b/vespajlib/src/main/java/com/yahoo/concurrent/classlock/ClassLocking.java
index e387d259f26..27b020b578d 100644
--- a/vespajlib/src/main/java/com/yahoo/concurrent/classlock/ClassLocking.java
+++ b/vespajlib/src/main/java/com/yahoo/concurrent/classlock/ClassLocking.java
@@ -8,7 +8,7 @@ import java.util.function.BooleanSupplier;
* @author valerijf
*/
public class ClassLocking {
- private final Map<Class<?>, ClassLock> classLocks = new HashMap<>();
+ private final Map<String, ClassLock> classLocks = new HashMap<>();
private final Object monitor = new Object();
public ClassLock lock(Class<?> clazz) {
@@ -17,7 +17,7 @@ public class ClassLocking {
public ClassLock lockWhile(Class<?> clazz, BooleanSupplier interruptCondition) {
synchronized (monitor) {
- while (classLocks.containsKey(clazz)) {
+ while (classLocks.containsKey(clazz.getName())) {
try {
monitor.wait();
} catch (InterruptedException ignored) {
@@ -29,15 +29,15 @@ public class ClassLocking {
}
ClassLock classLock = new ClassLock(this, clazz);
- classLocks.put(clazz, classLock);
+ classLocks.put(clazz.getName(), classLock);
return classLock;
}
}
void unlock(Class<?> clazz, ClassLock classLock) {
synchronized (monitor) {
- if (classLock.equals(classLocks.get(clazz))) {
- classLocks.remove(clazz);
+ if (classLock.equals(classLocks.get(clazz.getName()))) {
+ classLocks.remove(clazz.getName());
monitor.notifyAll();
} else {
throw new IllegalArgumentException("Lock has already been released");