Lock Implementation

makise-co · Aug 30, 2020 · 4571103 · 4571103
1 parent ed8150e
commit 4571103
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/Lock.php b/src/Lock.php
@@ -50,7 +50,7 @@ public function unlock(): void
         $queue = $this->queue;
         $this->queue = [];
 
-        foreach ($queue as $key => $cid) {
+        foreach ($queue as $cid => $val) {
             Coroutine::resume($cid);
         }
     }
@@ -72,7 +72,9 @@ private function blockWithTimeout(float $timeout): bool
 
         $this->block();
 
-        if (!$timedOut) {
+        if ($timedOut) {
+            unset($this->queue[$cid]);
+        } else {
             Timer::clear($tid);
         }
 
@@ -81,7 +83,7 @@ private function blockWithTimeout(float $timeout): bool
 
     private function block(): void
     {
-        $this->queue[] = Coroutine::getCid();
+        $this->queue[Coroutine::getCid()] = null;
         Coroutine::yield();
     }
 }