diff --git a/src/utils/src/Coroutine/Concurrent.php b/src/utils/src/Coroutine/Concurrent.php index 4887c469d..7ce93b219 100644 --- a/src/utils/src/Coroutine/Concurrent.php +++ b/src/utils/src/Coroutine/Concurrent.php @@ -12,6 +12,7 @@ declare(strict_types=1); namespace Hyperf\Utils\Coroutine; +use Hyperf\Utils\Coroutine; use Swoole\Coroutine\Channel; class Concurrent @@ -45,7 +46,7 @@ class Concurrent } } - go(function () use ($callable) { + Coroutine::create(function () use ($callable) { $callable(); $this->channel->pop($this->timeout); });