fix bug

white-poto · Nov 23, 2015 · c7dba87 · c7dba87
1 parent bd10e4e
commit c7dba87
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/src/AbstractPool.php b/src/AbstractPool.php
@@ -75,6 +75,21 @@ public function aliveCount()
         return $count;
     }
 
+    /**
+     * if all processes are stopped
+     *
+     * @return bool
+     */
+    public function isFinished()
+    {
+        foreach ($this->processes as $process) {
+            if (!$process->isStopped()) {
+                return false;
+            }
+        }
+        return true;
+    }
+
     /**
      * waiting for the sub processes to exit
      *

diff --git a/src/FixedPool.php b/src/FixedPool.php
@@ -44,6 +44,9 @@ public function execute(Process $process)
     public function wait($block = false, $interval = 100)
     {
         do {
+            if ($this->isFinished()) {
+                return;
+            }
             parent::wait(false);
             if ($this->aliveCount() < $this->max) {
                 foreach ($this->processes as $process) {