register timeout handlers on php 7.1

src/Illuminate/Queue/Worker.php

@@ -70,6 +70,8 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
         $lastRestart = $this->getTimestampOfLastQueueRestart();
 
         while (true) {
+            $this->registerTimeoutHandler($options);
+
             if ($this->daemonShouldRun()) {
                 $this->runNextJob($connectionName, $queue, $options);
             } else {
@@ -83,6 +85,29 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
         }
     }
 
+    /**
+     * Register the worker timeout handler (PHP 7.1+).
+     *
+     * @param  WorkerOptions  $options
+     * @return void
+     */
+    protected function registerTimeoutHandler(WorkerOptions $options)
+    {
+        if (version_compare(PHP_VERSION, '7.1.0') < 0 || ! extension_loaded('pcntl')) {
+            return;
+        }
+
+        pcntl_async_signals(true);
+
+        pcntl_signal(SIGALRM, function () {
+            $this->exceptions->report(new TimeoutException("A queue worker timed out while processing a job."));
+
+            exit(1);
+        });
+
+        pcntl_alarm($options->timeout + $options->sleep);
+    }
+
     /**
      * Determine if the daemon should process on this iteration.
      *