wenjy / php-redis

src/Lock.php

Spacing +7 added lines, -7 removed lines

@@ -24,7 +24,7 @@ 
      */
     public function acquireLock(string $lockName, $acquireTimeout = 10, $lockTimeout = 10)
     {
-        $lockName = 'lock:' . $lockName;
+        $lockName = 'lock:'.$lockName;
         $identifier = $this->getIdentifier();
         $end = time() + $acquireTimeout;
         while (time() < $end) {
@@ -47,7 +47,7 @@ 
      */
     public function releaseLock(string $lockName, string $identifier)
     {
-        $lockName = 'lock:' . $lockName;
+        $lockName = 'lock:'.$lockName;
         while (true) {
             $this->redis->watch($lockName);
             if ($this->redis->get($lockName) == $identifier) {
@@ -76,8 +76,8 @@ 
     {
         $identifier = $this->getIdentifier();
         $microTime = $this->microTimeFloat();
-        $ownerZset = $semname . ':owner';
-        $counterStr = $semname . ':counter';
+        $ownerZset = $semname.':owner';
+        $counterStr = $semname.':counter';
 
         // 清理过期的信号量持有者
         $this->redis->zremrangebyscore($semname, '-inf', $microTime + $timeout);
@@ -109,8 +109,8 @@ 
     public function releaseFairSemaphore($semname, $identifier)
     {
         $this->redis->zrem($semname, $identifier);
-        $ownerZset = $semname . ':owner';
-        return (bool)$this->redis->zrem($ownerZset, $identifier);
+        $ownerZset = $semname.':owner';
+        return (bool) $this->redis->zrem($ownerZset, $identifier);
     }
 
     /**
@@ -155,7 +155,7 @@ 
     protected function microTimeFloat()
     {
         list($usec, $sec) = explode(' ', microtime());
-        return ((float)$usec + (float)$sec);
+        return ((float) $usec + (float) $sec);
     }
 
     protected function getIdentifier()