Server : ApacheSystem : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64 User : addictionfreeind ( 1003) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Directory : /home/addictionfreeind/www/admin1/vendor/amphp/parallel/lib/Worker/Internal/ |
Upload File : |
<?php
namespace Amp\Parallel\Worker\Internal;
use Amp\Parallel\Worker\Task;
use Amp\Parallel\Worker\Worker;
use Amp\Promise;
/** @internal */
final class PooledWorker implements Worker
{
/** @var callable */
private $push;
/** @var Worker */
private $worker;
/**
* @param Worker $worker
* @param callable $push Callable to push the worker back into the queue.
*/
public function __construct(Worker $worker, callable $push)
{
$this->worker = $worker;
$this->push = $push;
}
/**
* Automatically pushes the worker back into the queue.
*/
public function __destruct()
{
($this->push)($this->worker);
}
/**
* {@inheritdoc}
*/
public function isRunning(): bool
{
return $this->worker->isRunning();
}
/**
* {@inheritdoc}
*/
public function isIdle(): bool
{
return $this->worker->isIdle();
}
/**
* {@inheritdoc}
*/
public function enqueue(Task $task): Promise
{
return $this->worker->enqueue($task);
}
/**
* {@inheritdoc}
*/
public function shutdown(): Promise
{
return $this->worker->shutdown();
}
/**
* {@inheritdoc}
*/
public function kill(): void
{
$this->worker->kill();
}
}