eee

function.php

@@ -13,6 +13,7 @@ use Kiri\Events\EventDispatch;
 use Kiri\Events\EventProvider;
 use Kiri\Router\Request;
 use Kiri\Router\Response;
+use Kiri\Server\Task\TaskExecute;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
 use Swoole\Process;
@@ -60,6 +61,67 @@ if (!function_exists('application')) {
 }
 
 
+if (!function_exists('task')) {
+    /**
+     * @param string $handler
+     * @param mixed $data
+     * @param int $dstWorkerId
+     * @param callable|null $finishFinishCallback
+     * @return void
+     * @throws Exception
+     */
+    function task(string $handler, mixed $data, int $dstWorkerId = -1, ?callable $finishFinishCallback = null): void
+    {
+        $execute = Kiri::getDi()->get(TaskExecute::class);
+        $execute->task($handler, $data, $dstWorkerId, $finishFinishCallback);
+    }
+}
+
+
+if (!function_exists('taskWait')) {
+    /**
+     * @param string $handler
+     * @param mixed $data
+     * @param float $timeout
+     * @param int $dstWorkerId
+     * @return mixed
+     * @throws Exception
+     */
+    function taskWait(string $handler, mixed $data, float $timeout = 0.5, int $dstWorkerId = -1): mixed
+    {
+        $execute = Kiri::getDi()->get(TaskExecute::class);
+        return $execute->taskWait($handler, $data, $timeout, $dstWorkerId);
+    }
+}
+
+
+if (!function_exists('taskCo')) {
+    /**
+     * @param array $tasks
+     * @param float $timeout
+     * @return false|array
+     */
+    function taskCo(array $tasks, float $timeout = 0.5): false|array
+    {
+        $execute = Kiri::getDi()->get(TaskExecute::class);
+        return $execute->taskCo($tasks, $timeout);
+    }
+}
+
+
+if (!function_exists('taskWaitMulti')) {
+    /**
+     * @param array $tasks
+     * @param float $timeout
+     * @return false|array
+     */
+    function taskWaitMulti(array $tasks, float $timeout = 0.5): false|array
+    {
+        $execute = Kiri::getDi()->get(TaskExecute::class);
+        return $execute->taskWaitMulti($tasks, $timeout);
+    }
+}
+
 if (!function_exists('make')) {
 
 
@@ -85,7 +147,8 @@ if (!function_exists('isJson')) {
 
     function isJson(?string $string): bool
     {
-        if (is_null($string)) return false;
+        if (is_null($string))
+            return false;
         return (str_starts_with($string, '{') && str_ends_with($string, '}'))
                || (str_ends_with($string, '[') && str_starts_with($string, ']'));
     }
@@ -145,7 +208,8 @@ if (!function_exists('checkPortIsAlready')) {
     {
         if (!Kiri::getPlatform()->isLinux()) {
             exec("lsof -i :" . $port . " | grep -i 'LISTEN' | awk '{print $2}'", $output);
-            if (empty($output)) return FALSE;
+            if (empty($output))
+                return FALSE;
             $output = explode(PHP_EOL, $output[0]);
             return $output[0];
         }
@@ -845,7 +909,8 @@ if (!function_exists('jTraceEx')) {
     {
         $starter = $seen ? 'Caused by: ' : '';
         $result  = [];
-        if (!$seen) $seen = [];
+        if (!$seen)
+            $seen = [];
         $trace    = $e->getTrace();
         $prev     = $e->getPrevious();
         $result[] = sprintf('%s%s: %s', $starter, $e::class, $e->getMessage());

kiri-engine/Error/ErrorHandler.php

@@ -11,17 +11,12 @@ namespace Kiri\Error;
 
 use Closure;
 use ErrorException;
-use Exception;
 use Kiri\Abstracts\Component;
-use Psr\Container\ContainerInterface;
-use Kiri\Di\Inject\Container;
-use ReflectionException;
 use Kiri\Events\OnSystemError;
 use Throwable;
 
 /**
  * Class ErrorHandler
- * hahahah
  * @package Kiri\Base
  * @property-read $asError
  */

kiri-engine/Error/StdoutLogger.php

@@ -9,7 +9,6 @@ use Monolog\Formatter\LineFormatter;
 use Monolog\Handler\RotatingFileHandler;
 use Monolog\Logger;
 use Psr\Log\LoggerInterface;
-use ReflectionException;
 
 
 /**

kiri-engine/Redis/Redis.php

@@ -9,12 +9,9 @@ declare(strict_types=1);
 
 namespace Kiri\Redis;
 
-use Exception;
 use Kiri;
 use Kiri\Exception\RedisConnectException;
 use Kiri\Pool\Pool;
-use RedisException;
-use wchat\common\Result;
 use function config;
 
 /**