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), $randWorkerId);
	}

}