2016-12-29 19:16:04 -06:00
|
|
|
<?php
|
2015-08-25 00:08:17 -05:00
|
|
|
|
2016-08-23 16:47:40 -05:00
|
|
|
namespace Amp\Parallel\Worker;
|
2016-08-18 11:04:48 -05:00
|
|
|
|
2017-11-29 15:01:32 -06:00
|
|
|
use Amp\Parallel\Context\Process;
|
2015-08-25 00:08:17 -05:00
|
|
|
|
2015-08-27 09:10:08 -05:00
|
|
|
/**
|
2018-02-27 20:02:22 +01:00
|
|
|
* A worker process that executes task objects.
|
2015-08-27 09:10:08 -05:00
|
|
|
*/
|
2018-10-07 09:50:45 -05:00
|
|
|
class WorkerProcess extends AbstractWorker
|
|
|
|
{
|
2017-12-10 15:37:33 -06:00
|
|
|
const SCRIPT_PATH = __DIR__ . "/Internal/worker-process.php";
|
|
|
|
|
2017-07-26 01:02:34 -05:00
|
|
|
/**
|
|
|
|
* @param string $envClassName Name of class implementing \Amp\Parallel\Worker\Environment to instigate.
|
|
|
|
* Defaults to \Amp\Parallel\Worker\BasicEnvironment.
|
|
|
|
* @param mixed[] $env Array of environment variables to pass to the worker. Empty array inherits from the current
|
|
|
|
* PHP process. See the $env parameter of \Amp\Process\Process::__construct().
|
2017-12-12 21:06:11 -06:00
|
|
|
* @param string|null $binary Path to PHP binary. Null will attempt to automatically locate the binary.
|
2017-12-10 15:37:33 -06:00
|
|
|
*
|
|
|
|
* @throws \Error If the PHP binary path given cannot be found or is not executable.
|
2017-07-26 01:02:34 -05:00
|
|
|
*/
|
2018-10-07 09:50:45 -05:00
|
|
|
public function __construct(string $envClassName = BasicEnvironment::class, array $env = [], string $binary = null)
|
|
|
|
{
|
2017-07-26 01:02:34 -05:00
|
|
|
$script = [
|
2017-12-10 15:37:33 -06:00
|
|
|
self::SCRIPT_PATH,
|
|
|
|
$envClassName,
|
2017-07-26 01:02:34 -05:00
|
|
|
];
|
2017-12-12 21:06:11 -06:00
|
|
|
parent::__construct(new Process($script, null, $env, $binary));
|
2015-08-25 00:08:17 -05:00
|
|
|
}
|
2015-08-27 09:10:08 -05:00
|
|
|
}
|