diff --git a/System/Pool/Redis.php b/System/Pool/Redis.php index cbf59a0b..4d484cfa 100644 --- a/System/Pool/Redis.php +++ b/System/Pool/Redis.php @@ -116,6 +116,7 @@ class Redis extends Pool return; } $this->push($coroutineName, Context::getContext($coroutineName)); + $this->remove($coroutineName); } /**