e

2022-01-09 03:49:02 +08:00
parent b5ad99332d
commit 550197de96
44 changed files with 2113 additions and 2113 deletions
@@ -1,92 +1,92 @@
-<?php
-
-namespace Server\Tasker;
-
-use Exception;
-use Kiri\Abstracts\Component;
-use Kiri\Core\HashMap;
-use Kiri\Kiri;
-use ReflectionException;
-use Server\Contract\OnTaskInterface;
-use Server\SwooleServerInterface;
-
-
-/**
- *
- */
-class AsyncTaskExecute extends Component
-{
-
-
-	/**
-	 * @var SwooleServerInterface|null
-	 */
-	public ?SwooleServerInterface $server = null;
-
-
-	private HashMap $hashMap;
-
-
-	/**
-	 *
-	 */
-	public function init()
-	{
-		$this->hashMap = new HashMap();
-	}
-
-
-	/**
-	 * @param string $key
-	 * @param $handler
-	 */
-	public function reg(string $key, $handler)
-	{
-		$this->hashMap->put($key, $handler);
-	}
-
-
-	/**
-	 * @param OnTaskInterface|string $handler
-	 * @param array $params
-	 * @param int|null $workerId
-	 * @throws Exception
-	 */
-	public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = null)
-	{
-		if (!$this->server) {
-			$this->server = Kiri::getDi()->get(SwooleServerInterface::class);
-		}
-		if ($workerId === null || $workerId <= $this->server->setting['worker_num']) {
-			$workerNum = $this->server->setting['worker_num'];
-			$taskerNum = $workerNum + $this->server->setting['task_worker_num'];
-			$workerId = random_int($workerNum, $taskerNum - 1);
-		}
-		if (is_string($handler)) {
-			$handler = $this->handle($handler, $params);
-		}
-		$this->server->task(serialize($handler), $workerId);
-	}
-
-
-	/**
-	 * @param $handler
-	 * @param $params
-	 * @return object
-	 * @throws ReflectionException
-	 * @throws Exception
-	 */
-	private function handle($handler, $params): object
-	{
-		if (!class_exists($handler) && $this->hashMap->has($handler)) {
-			$handler = $this->hashMap->get($handler);
-		}
-		$implements = $this->container->getReflect($handler);
-		if (!in_array(OnTaskInterface::class, $implements->getInterfaceNames())) {
-			throw new Exception('Task must instance ' . OnTaskInterface::class);
-		}
-		return $implements->newInstanceArgs($params);
-	}
-
-
-}
+<?php
+
+namespace Server\Tasker;
+
+use Exception;
+use Kiri\Abstracts\Component;
+use Kiri\Core\HashMap;
+use Kiri\Kiri;
+use ReflectionException;
+use Server\Contract\OnTaskInterface;
+use Server\SwooleServerInterface;
+
+
+/**
+ *
+ */
+class AsyncTaskExecute extends Component
+{
+
+
+	/**
+	 * @var SwooleServerInterface|null
+	 */
+	public ?SwooleServerInterface $server = null;
+
+
+	private HashMap $hashMap;
+
+
+	/**
+	 *
+	 */
+	public function init()
+	{
+		$this->hashMap = new HashMap();
+	}
+
+
+	/**
+	 * @param string $key
+	 * @param $handler
+	 */
+	public function reg(string $key, $handler)
+	{
+		$this->hashMap->put($key, $handler);
+	}
+
+
+	/**
+	 * @param OnTaskInterface|string $handler
+	 * @param array $params
+	 * @param int|null $workerId
+	 * @throws Exception
+	 */
+	public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = null)
+	{
+		if (!$this->server) {
+			$this->server = Kiri::getDi()->get(SwooleServerInterface::class);
+		}
+		if ($workerId === null || $workerId <= $this->server->setting['worker_num']) {
+			$workerNum = $this->server->setting['worker_num'];
+			$taskerNum = $workerNum + $this->server->setting['task_worker_num'];
+			$workerId = random_int($workerNum, $taskerNum - 1);
+		}
+		if (is_string($handler)) {
+			$handler = $this->handle($handler, $params);
+		}
+		$this->server->task(serialize($handler), $workerId);
+	}
+
+
+	/**
+	 * @param $handler
+	 * @param $params
+	 * @return object
+	 * @throws ReflectionException
+	 * @throws Exception
+	 */
+	private function handle($handler, $params): object
+	{
+		if (!class_exists($handler) && $this->hashMap->has($handler)) {
+			$handler = $this->hashMap->get($handler);
+		}
+		$implements = $this->container->getReflect($handler);
+		if (!in_array(OnTaskInterface::class, $implements->getInterfaceNames())) {
+			throw new Exception('Task must instance ' . OnTaskInterface::class);
+		}
+		return $implements->newInstanceArgs($params);
+	}
+
+
+}
@@ -1,94 +1,94 @@
-<?php
-
-
-namespace Server\Tasker;
-
-
-use Kiri\Annotation\Inject;
-use Kiri\Abstracts\Logger;
-use Kiri\Exception\ConfigException;
-use Server\Contract\OnTaskInterface;
-use Swoole\Server;
-
-
-/**
- * Class OnServerTask
- * @package Server\Task
- */
-class OnServerTask
-{
-
-
-	#[Inject(Logger::class)]
-	public Logger $logger;
-
-
-	/**
-	 * @param Server $server
-	 * @param int $task_id
-	 * @param int $src_worker_id
-	 * @param mixed $data
-	 * @throws ConfigException
-	 */
-	public function onTask(Server $server, int $task_id, int $src_worker_id, mixed $data)
-	{
-		try {
-			$data = $this->resolve($data);
-		} catch (\Throwable $exception) {
-			$data = jTraceEx($exception);
-
-			$this->logger->error('task', [$data]);
-		} finally {
-			$server->finish($data);
-		}
-	}
-
-
-	/**
-	 * @param Server $server
-	 * @param Server\Task $task
-	 * @throws ConfigException
-	 */
-	public function onCoroutineTask(Server $server, Server\Task $task)
-	{
-		try {
-			$data = $this->resolve($task->data);
-		} catch (\Throwable $exception) {
-			$data = jTraceEx($exception);
-
-			$this->logger->error('task', [$data]);
-		} finally {
-			$server->finish($data);
-		}
-	}
-
-
-	/**
-	 * @param $data
-	 * @return null
-	 */
-	private function resolve($data)
-	{
-		$execute = unserialize($data);
-		if ($execute instanceof OnTaskInterface) {
-			return $execute->execute();
-		}
-		return null;
-	}
-
-
-	/**
-	 * @param Server $server
-	 * @param int $task_id
-	 * @param mixed $data
-	 */
-	public function onFinish(Server $server, int $task_id, mixed $data)
-	{
-		if (!($data instanceof OnTaskInterface)) {
-			return;
-		}
-		$data->finish($server, $task_id);
-	}
-
-
-}
+<?php
+
+
+namespace Server\Tasker;
+
+
+use Kiri\Annotation\Inject;
+use Kiri\Abstracts\Logger;
+use Kiri\Exception\ConfigException;
+use Server\Contract\OnTaskInterface;
+use Swoole\Server;
+
+
+/**
+ * Class OnServerTask
+ * @package Server\Task
+ */
+class OnServerTask
+{
+
+
+	#[Inject(Logger::class)]
+	public Logger $logger;
+
+
+	/**
+	 * @param Server $server
+	 * @param int $task_id
+	 * @param int $src_worker_id
+	 * @param mixed $data
+	 * @throws ConfigException
+	 */
+	public function onTask(Server $server, int $task_id, int $src_worker_id, mixed $data)
+	{
+		try {
+			$data = $this->resolve($data);
+		} catch (\Throwable $exception) {
+			$data = jTraceEx($exception);
+
+			$this->logger->error('task', [$data]);
+		} finally {
+			$server->finish($data);
+		}
+	}
+
+
+	/**
+	 * @param Server $server
+	 * @param Server\Task $task
+	 * @throws ConfigException
+	 */
+	public function onCoroutineTask(Server $server, Server\Task $task)
+	{
+		try {
+			$data = $this->resolve($task->data);
+		} catch (\Throwable $exception) {
+			$data = jTraceEx($exception);
+
+			$this->logger->error('task', [$data]);
+		} finally {
+			$server->finish($data);
+		}
+	}
+
+
+	/**
+	 * @param $data
+	 * @return null
+	 */
+	private function resolve($data)
+	{
+		$execute = unserialize($data);
+		if ($execute instanceof OnTaskInterface) {
+			return $execute->execute();
+		}
+		return null;
+	}
+
+
+	/**
+	 * @param Server $server
+	 * @param int $task_id
+	 * @param mixed $data
+	 */
+	public function onFinish(Server $server, int $task_id, mixed $data)
+	{
+		if (!($data instanceof OnTaskInterface)) {
+			return;
+		}
+		$data->finish($server, $task_id);
+	}
+
+
+}