kiri-core/System/Async.php

<?php


namespace Snowflake;


use Exception;
use HttpServer\IInterface\Task;
use ReflectionException;
use Snowflake\Abstracts\Component;

/**
 * Class Async
 * @package Snowflake
 */
class Async extends Component
{


    private array $_absences = [];


    /**
     * @param string $name
     * @param Task $handler
     */
    public function addAsync(string $name, Task $handler)
    {
        $this->_absences[$name] = $handler;
    }


    /**
     * @param string $name
     * @param array $params
     * @throws Exception
     */
    public function dispatch(string $name, array $params = [])
    {
        $server = Snowflake::app()->getSwoole();
        if (!isset($server->setting['task_worker_num'])) {
            return;
        }

        if (!isset($this->_absences[$name])) {
            return;
        }

        /** @var Task $class */
        $class = $this->_absences[$name];
        $class->setParams($params);

        $randWorkerId = random_int(0, $server->setting['task_worker_num'] - 1);

        $server->task(swoole_serialize([$class, 'onHandler']), $randWorkerId);
    }

}