2019-02-13 21:19:01 +01:00
|
|
|
<?php
|
|
|
|
|
|
|
|
namespace Amp\Parallel\Worker;
|
|
|
|
|
|
|
|
use Amp\Parallel\Context\Parallel;
|
|
|
|
|
|
|
|
/**
|
2019-02-18 06:50:41 +01:00
|
|
|
* A worker parallel extension thread that executes task objects.
|
2019-02-13 21:19:01 +01:00
|
|
|
*/
|
|
|
|
final class WorkerParallel extends TaskWorker
|
|
|
|
{
|
2019-02-18 06:50:41 +01:00
|
|
|
const SCRIPT_PATH = __DIR__ . "/Internal/worker-process.php";
|
2019-02-13 21:19:01 +01:00
|
|
|
|
|
|
|
/**
|
|
|
|
* @param string $envClassName Name of class implementing \Amp\Parallel\Worker\Environment to instigate.
|
|
|
|
* Defaults to \Amp\Parallel\Worker\BasicEnvironment.
|
2019-02-22 22:43:42 +01:00
|
|
|
* @param string|null Path to custom bootstrap file.
|
2019-02-13 21:19:01 +01:00
|
|
|
*
|
|
|
|
* @throws \Error If the PHP binary path given cannot be found or is not executable.
|
|
|
|
*/
|
2019-02-22 22:43:42 +01:00
|
|
|
public function __construct(string $envClassName = BasicEnvironment::class, string $bootstrapPath = null)
|
2019-02-13 21:19:01 +01:00
|
|
|
{
|
2019-02-21 00:39:39 +01:00
|
|
|
$script = [
|
2019-02-18 06:50:41 +01:00
|
|
|
self::SCRIPT_PATH,
|
|
|
|
$envClassName,
|
2019-02-21 00:39:39 +01:00
|
|
|
];
|
|
|
|
|
2019-02-22 22:43:42 +01:00
|
|
|
if ($bootstrapPath !== null) {
|
|
|
|
$script[] = $bootstrapPath;
|
2019-02-21 00:39:39 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
parent::__construct(new Parallel($script));
|
2019-02-13 21:19:01 +01:00
|
|
|
}
|
|
|
|
}
|