Fixed reentrant locking mechanism for PoorMansLock

2018-08-05 13:15:31 +07:00
parent afe88e260c
commit b5a7942b67
1 changed files with 4 additions and 2 deletions
--- a/event-loop/src/main/java/mc/core/events/lock/PoorMansLock.java
+++ b/event-loop/src/main/java/mc/core/events/lock/PoorMansLock.java
@@ -27,8 +27,10 @@ public class PoorMansLock {
    }

    public synchronized void lock() {
-        if (owner != null && owner != Thread.currentThread()) {
-            // ToDo: do we need to await for unlock?
+        if(owner == Thread.currentThread())
+            return;
+
+        if (owner != null) {
            throw new RuntimeException("Unable to lock this resource: already in use");
        }