Merge pull request #4 from RunnerLee/master

更新进程命名方法

Author: JanHuang

examples/process/name.php

@@ -0,0 +1,40 @@
+<?php
+/**
+ * @author    jan huang <bboyjanhuang@gmail.com>
+ * @copyright 2016
+ *
+ * @link      https://www.github.com/janhuang
+ * @link      http://www.fast-d.cn/
+ */
+
+use FastD\Swoole\Process;
+
+include __DIR__ . '/../../vendor/autoload.php';
+
+class DemoProcess extends Process
+{
+    /**
+     * Process handle
+     *
+     * @return callable
+     */
+    public function handle(swoole_process $swoole_process)
+    {
+        timer_tick(1000, function ($id) {
+            static $index = 0;
+            $index++;
+            echo $index . PHP_EOL;
+            if ($index === 10) {
+                timer_clear($id);
+            }
+        });
+    }
+}
+
+$process = new DemoProcess('fastd swoole');
+
+$process->start();
+
+$process->wait(function ($ret) {
+    echo 'PID: ' . $ret['pid'];
+});

src/Process.php

@@ -77,7 +77,7 @@ public function __construct($name = null, $callback = null, $redirect = false, $
 
         $this->callback = null === $callback ? [$this, 'handle'] : $callback;
 
-        $this->process = new swoole_process($this->callback, $redirect, $pipe);
+        $this->process = new swoole_process([$this, 'runProcess'], $redirect, $pipe);
     }
 
     /**
@@ -199,9 +199,6 @@ public function exists($pid)
      */
     public function start()
     {
-        if (!empty($this->name)) {
-            process_rename($this->name);
-        }
         if (true === $this->daemonize) {
             $this->process->daemon();
         }
@@ -255,8 +252,19 @@ public function getProcess()
     /**
      * Process handle
      *
-     * @param $swoole_process
+     * @param swoole_process $swoole_process
      * @return callable
      */
     public function handle(swoole_process $swoole_process){}
+
+    /**
+     * @param swoole_process $worker
+     * @return void
+     */
+    public function runProcess(swoole_process $worker)
+    {
+        process_rename($this->name);
+
+        call_user_func($this->callback, $worker);
+    }
 }