兼容关闭 Swoole 短名称的场景

Author: Yurunsoft

src/Process/SwooleQueueConsumerProcess.php

@@ -58,7 +58,7 @@ public function run(\Swoole\Process $process): void
                 $processPool = new \Imi\Swoole\Process\Pool($options['process']);
                 $configs = $options['configs'];
                 $processPool->on('WorkerStart', function (\Imi\Swoole\Process\Pool\WorkerEventParam $e) use ($group, $configs) {
-                    go(function () use ($group, $configs) {
+                    Coroutine::create(function () use ($group, $configs) {
                         \Swoole\Runtime::enableCoroutine(true);
                         Imi::setProcessName('process', [
                             'processName'   => 'QueueConsumer-' . $group,

tests/Queue/BaseQueueTest.php

@@ -41,8 +41,8 @@ public function testPopTimeout(): void
     {
         $message = $totalTime = null;
         $channel = new Channel(1);
-        go(function () use (&$message, &$totalTime, $channel) {
-            go(function () use ($channel) {
+        Coroutine::create(function () use (&$message, &$totalTime, $channel) {
+            Coroutine::create(function () use ($channel) {
                 Coroutine::sleep(1);
                 $message = new Message();
                 $message->setMessage('a');