Fix Swow first request hang on Windows

Author: walkor

src/Events/Select.php

@@ -364,8 +364,6 @@ protected function setNextTickTime(float $nextTickTime): void
     {
         $this->nextTickTime = $nextTickTime;
         if ($nextTickTime == 0) {
-            // Swow will affect the signal interruption characteristics of stream_select,
-            // so a shorter timeout should be used to detect signals.
             $this->selectTimeout = self::MAX_SELECT_TIMOUT_US;
             return;
         }

src/Events/Swow.php

@@ -144,10 +144,10 @@ public function onReadable($stream, callable $func): void
                     }
                     // Under Windows, setting a timeout is necessary; otherwise, the accept cannot be listened to.
                     // Setting it to 1000ms will result in a 1-second delay for the first accept under Windows.
-                    $rEvent = stream_poll_one($stream, STREAM_POLLIN | STREAM_POLLHUP, 1000);
                     if (!isset($this->readEvents[$fd]) || $this->readEvents[$fd] !== Coroutine::getCurrent()) {
                         break;
                     }
+                    $rEvent = stream_poll_one($stream, STREAM_POLLIN | STREAM_POLLHUP, 1000);
                     if ($rEvent !== STREAM_POLLNONE) {
                         $this->safeCall($func, [$stream]);
                     }

src/Worker.php

@@ -61,7 +61,7 @@ class Worker
      *
      * @var string
      */
-    final public const VERSION = '5.1.2';
+    final public const VERSION = '5.1.3';
 
     /**
      * Status initial.
@@ -1594,7 +1594,17 @@ protected static function forkWorkersForWindows(): void
             restore_error_handler();
 
             // Add an empty timer to prevent the event-loop from exiting.
-            Timer::add(1000000, function (){});
+            Timer::add(0.8, function (){});
+
+            // Compatibility with the bug in Swow where the first request on Windows fails to trigger stream_select.
+            if (extension_loaded('swow')) {
+                Timer::delay(0.1 , function(){
+                    $stream = fopen(__FILE__, 'r');
+                    static::$globalEvent->onReadable($stream, function($stream) {
+                        static::$globalEvent->offReadable($stream);
+                    });
+                });
+            }
 
             // Display UI.
             static::safeEcho(str_pad($worker->name, 48) . str_pad($worker->getSocketName(), 36) . str_pad('1', 10) . "  [ok]\n");