54 lines
1.1 KiB
PHP
54 lines
1.1 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace Kiri\Server\Task;
|
||
|
|
|
||
|
|
use Kiri\Di\Inject\Container;
|
||
|
|
use Kiri\Server\ServerInterface;
|
||
|
|
|
||
|
|
class TaskExecute implements TaskInterface
|
||
|
|
{
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @var ServerInterface
|
||
|
|
*/
|
||
|
|
#[Container(ServerInterface::class)]
|
||
|
|
public ServerInterface $server;
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param mixed $data
|
||
|
|
* @param float $timeout
|
||
|
|
* @param int $dstWorkerId
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
public function taskWait(mixed $data, float $timeout = 0.5, int $dstWorkerId = -1): mixed
|
||
|
|
{
|
||
|
|
return $this->server->taskwait($data, $timeout, $dstWorkerId);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param array $tasks
|
||
|
|
* @param float $timeout
|
||
|
|
* @return false|array
|
||
|
|
*/
|
||
|
|
public function taskCo(array $tasks, float $timeout = 0.5): false|array
|
||
|
|
{
|
||
|
|
return $this->server->taskCo($tasks, $timeout);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param array $tasks
|
||
|
|
* @param float $timeout
|
||
|
|
* @return false|array
|
||
|
|
*/
|
||
|
|
public function taskWaitMulti(array $tasks, float $timeout = 0.5): false|array
|
||
|
|
{
|
||
|
|
return $this->server->taskWaitMulti($tasks, $timeout);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|