pthreads-reactphp

composer.json

{
    "require": {
        "iainconnor/composer-pthreads": "^1.0"
    }
}

Executor.php

<?php 

use IainConnor\ComposerPthreads\AutoloadWorker;
use IainConnor\ComposerPthreads\ResponseDataBundle;
use Pool;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;
use React\Promise\PromiseInterface;

class Executor
{
    private $pool;
    private $loop;

    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
        $this->pool = new Pool(4, AutoloadWorker::class, [__DIR__.'/../../autoload.php']);
    }

    public function shutdown()
    {
        $this->pool->shutdown();
    }

    public function async(callable $closure): PromiseInterface
    {
        $defer = new Deferred();

        $data = new ResponseDataBundle();

        $task = new Task($closure, $data);

        $this->pool->submit($task);

        $listener = function () use (&$listener, $data, $task, $defer) {
            if ($task->isDone()) {
                $defer->resolve($data->getData());
            } else {
                $this->loop->futureTick($listener);
            }
        };

        $this->loop->futureTick($listener);

        return $defer->promise();
    }
}

Task.php

<?php

use IainConnor\ComposerPthreads\ResponseDataBundle;

class Task extends \Volatile
{
    private $closure;
    private $data;
    private $done = false;

    public function __construct(callable $closure, ResponseDataBundle $data)
    {
        $this->data = $data;
        $this->closure = $closure;
    }

    public function run()
    {
        $this->data->setData(($this->closure)());
        $this->done = true;
    }

    public function isDone(): bool
    {
        return $this->done;
    }
}