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.
|
|
|
|
*
|
|
|
|
* @throws \Error If the PHP binary path given cannot be found or is not executable.
|
|
|
|
*/
|
|
|
|
public function __construct(string $envClassName = BasicEnvironment::class)
|
|
|
|
{
|
2019-02-18 06:50:41 +01:00
|
|
|
parent::__construct(new Parallel([
|
|
|
|
self::SCRIPT_PATH,
|
|
|
|
$envClassName,
|
|
|
|
]));
|
2019-02-13 21:19:01 +01:00
|
|
|
}
|
|
|
|
}
|