#16: Timeout of queue reading lock for db driver

yiisoft · Mar 26, 2017 · c167d95 · c167d95
1 parent 863237b
commit c167d95
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/db/Driver.php b/src/db/Driver.php
@@ -32,6 +32,10 @@ class Driver extends BaseDriver implements BootstrapInterface
      * @var Mutex|array|string
      */
     public $mutex = 'mutex';
+    /**
+     * @var int timeout
+     */
+    public $mutexTimeout = 3;
     /**
      * @var string table name
      */
@@ -125,7 +129,7 @@ public function listen($delay)
      */
     protected function pop()
     {
-        if (!$this->mutex->acquire(__CLASS__ . $this->channel, 3)) {
+        if (!$this->mutex->acquire(__CLASS__ . $this->channel, $this->mutexTimeout)) {
             throw new Exception("Has not waited the lock.");
         }