修复创建最大进程数目之后可继续创建

extend/catcher/library/crontab/Master.php

@@ -23,14 +23,21 @@ class Master
      *
      * @var int
      */
-    protected $maxNum = 10;
+    protected $maxNum;
 
     /**
      * 常驻 process
      *
      * @var int
      */
-    protected $staticNum = 1;
+    protected $staticNum;
+
+    /**
+     * 临时进程数量
+     *
+     * @var int
+     */
+    protected $temporaryNum = 0;
 
     /**
      * 存储 process 信息
@@ -58,15 +65,6 @@ class Master
      */
     protected $master_start_at;
 
-
-    protected $table;
-    /**
-     * 日志
-     *
-     * @var
-     */
-    protected $logHandle;
-
     // 版本
     const VERSION = '1.0.0';
 
@@ -157,14 +155,29 @@ class Master
      */
     protected function createProcess(Cron $cron)
     {
-        $process = new Process(function (Process $process) use($cron) {
+        if ($this->isCanCreateTemporaryProcess()) {
-            $cron->run();
+            $process = new Process(function (Process $process) use ($cron) {
-            $process->exit();
+                $cron->run();
-        });
+                $process->exit();
+            });
 
-        // $process->name(sprintf('worker: '));
+            // $process->name(sprintf('worker: '));
 
-        $process->start();
+            $process->start();
+
+            $this->temporaryNum += 1;
+        }
+    }
+
+    /**
+     * 是否可以创建临时进程
+     *
+     * @time 2020年07月09日
+     * @return bool
+     */
+    protected function isCanCreateTemporaryProcess()
+    {
+        return ($this->table->count() + $this->temporaryNum) < $this->maxNum;
     }
 
     /**

extend/catcher/library/crontab/Process.php

@@ -98,7 +98,7 @@ trait Process
             }
         }
 
-        // 获取相应的状态
+        // 获取相应的进程投递任务
         if (isset($this->processes[$pid])) {
             return [true, $this->processes[$pid]];
         }

extend/catcher/library/crontab/RegisterSignal.php

@@ -66,6 +66,8 @@ trait RegisterSignal
                     $this->unsetWorkerStatus($res['pid']);
                     unset($this->processes[$res['pid']]);
                 }
+                // 临时进程数目减少一次
+                $this->temporaryNum -= 1;
             }
         };
     }