Merge pull request #177 from igormukhingmailcom/pcntl

Proper reaction for SIGTERM and SIGINT

src/Workflow.php

@@ -52,6 +52,11 @@ class Workflow implements WorkflowInterface
      */
     private $writers = [];
 
+    /**
+     * @var boolean For internal use
+     */
+    protected $shouldStop = false;
+
     /**
      * Construct a workflow
      *
@@ -116,8 +121,20 @@ public function process()
             $writer->prepare();
         }
 
+        $this->shouldStop = false;
+        if (is_callable('pcntl_signal')) {
+            pcntl_signal(SIGTERM, array($this, 'stop'));
+            pcntl_signal(SIGINT, array($this, 'stop'));
+        }
+
         // Read all items
         foreach ($this->reader as $index => $item) {
+
+            if (is_callable('pcntl_signal_dispatch')) {
+                pcntl_signal_dispatch();
+            }
+            if ( $this->shouldStop ) break;
+
             try {
                 foreach (clone $this->steps as $step) {
                     if (false === $step->process($item)) {
@@ -151,6 +168,14 @@ public function process()
         return new Result($this->name, $startTime, new \DateTime, $count, $exceptions);
     }
 
+    /**
+     * Stops processing and force return Result from process() function
+     */
+    public function stop()
+    {
+        $this->shouldStop = true;
+    }
+
     /**
      * Set skipItemOnFailure.
      *