+add phpBin to set a specific php version when run the script or call…

…back

=update readme

README.md

@@ -20,6 +20,10 @@
 
  - can get callable function return value
 
+ - You can specify the PHP path for asynchronous execution scripts by specifying the phpBin parameter.
+
+ - Exception Handling
+
 ## Installation
 You can use composer to install this library from the command line.
 
@@ -36,7 +40,7 @@ composer require sinacms/multiprocess
 
 use Mutilprocessing\Async;
 
-Async::create()->run('task.php', ['runTest'.$i]);
+Async::create()->start('task.php', ['runTest'.$i]);
 ```
 
 ### distribute tasks by a simple function and async execute
@@ -50,7 +54,7 @@ use Mutilprocessing\Async;
 
 Async::create()->startFunc(function($param1, $param2) {
     echo $param1.$param2.PHP_EOL;
-}, ['param1' => 'hello', 'param2' => ' world'])
+}, ['param1' => 'hello', 'param2' => ' world']);
 
 $func = function ($param1, $param2) {
     echo "this is an another func";
@@ -147,8 +151,8 @@ Async::discard();
   * ### Async
    * ### option shorthand
   * public static function create()
-  * public static function start($scriptname, $args, $envs = [])
-  * public function startFunc(callable $function, $args = [])
+  * public static function start($scriptname, $args, $phpBin="", $envs = [])
+  * public function startFunc(callable $function, $args = [], $phpBin="")
   * public static function discard()
   * public static function wait(callable $logHandler = null)
   * public static function getArgs($argv = null)
@@ -158,7 +162,7 @@ Async::discard();
   * public static function genTmp(callable $function)
 
 
-## Plan
+## Todo
   * regCallback for each execution (on process)
   * add multi execution unit and start once
 

src/Async.php

@@ -4,8 +4,10 @@
 
 require_once __DIR__ . '/FunctionParser.php';
 require_once __DIR__ . '/Exception/FileNotFoundException.php';
+require_once __DIR__ . '/Exception/PHPBinNotFoundException.php';
 
 use Mutilprocessing\Exception\FileNotFoundException;
+use Mutilprocessing\Exception\PHPBinNotFoundException;
 use Mutilprocessing\FunctionParser;
 
 class Async
@@ -43,16 +45,16 @@ public static function discard()
      * @param array $args <p>
      * Input you want to execute the required parameters in function
      * </p>
+     * @param string $phpBin You can specify the PHP path for asynchronous execution scripts.
      * @param array $envs
      * @return $this
      */
-    public function start($scriptname, $args = [], $envs = [])
+    public function start($scriptname, $args = [], $phpBin = null, $envs = [])
     {
         if ($scriptname == 'callbackStub.php') {
             $cwd = __DIR__;
         } else {
             $cwd = '.';
-            // judge if file exists
             if (!is_file($scriptname)) {
                 throw new FileNotFoundException($scriptname." is not found");
             }
@@ -62,9 +64,18 @@ public function start($scriptname, $args = [], $envs = [])
         } else {
             $argsStr = escapeshellarg(base64_encode(json_encode($args)));
         }
+        if ($phpBin !== null && is_string($phpBin)) {
+            // check if php-bin is validate
+            if (!is_file($phpBin)) {
+                throw new PHPBinNotFoundException("PHP Binary :".$phpBin."is not found");
+            }
+            $cmd = "{$phpBin} {$scriptname} '$argsStr' & ";
+        } else {
+            $cmd = "php $scriptname '$argsStr' & ";
+        }
         $this -> argStr = $argsStr;
         $this->proccess = proc_open(
-            "php $scriptname '$argsStr' & ",
+            $cmd,
             array(
                 0 => array('pipe', 'r'), //stdin (用fwrite写入数据给管道)
                 1 => array('pipe', 'w'), //stdout(用stream_get_contents获取管道输出)
@@ -87,11 +98,11 @@ public function start($scriptname, $args = [], $envs = [])
      * Input you want to execute the required parameters in function
      * </p>
      */
-    public function startFunc(callable $function, $args = [])
+    public function startFunc(callable $function, $args = [], $phpBin = null)
     {
         $funcBody = FunctionParser::genTmp($function);
         $args['body'] = $funcBody;
-        $this -> start('callbackStub.php', $args);
+        $this -> start('callbackStub.php', $args, $phpBin);
     }
 
     /**

src/Exception/PHPBinNotFoundException.php

@@ -0,0 +1,14 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: shixi_qingzhe
+ * Date: 18/8/10
+ * Time: 下午3:41
+ */
+
+namespace Mutilprocessing\Exception;
+
+
+class PHPBinNotFoundException extends \Exception
+{
+}