Workerman Coroutine

Author: walkor

composer.json

@@ -3,7 +3,7 @@
   "type": "library",
   "license": "MIT",
   "require": {
-    "workerman/webman-framework": "^2.0 || dev-master",
+    "workerman/webman-framework": "^2.1 || dev-master",
     "topthink/think-container": "^2.0",
     "psr/simple-cache": "^1.0|^2.0|^3.0"
   },

src/Manager.php

@@ -17,7 +17,8 @@
 use think\helper\Str;
 use Throwable;
 use Webman\Context;
-use Webman\Coroutine\Pool;
+use Workerman\Coroutine\Coroutine;
+use Workerman\Coroutine\Pool;
 
 abstract class Manager
 {
@@ -163,7 +164,7 @@ protected function createDriver(string $name): mixed
                     $connection = static::$pools[$name]->get();
                     Context::set($key, $connection);
                 } finally {
-                    Context::onDestroy(function () use ($connection, $name) {
+                    Coroutine::defer(function () use ($connection, $name) {
                         try {
                             $connection && static::$pools[$name]->put($connection);
                         } catch (Throwable) {

src/driver/Redis.php

@@ -16,7 +16,7 @@
 use DateInterval;
 use DateTimeInterface;
 use RedisException;
-use Webman\Coroutine\Pool;
+use Workerman\Coroutine\Pool;
 use Webman\ThinkCache\Driver;
 
 class Redis extends Driver