Job: utilized PHP 8.5 stream_select() fix for true parallel execution on Windows

PHP 8.5 fixed stream_select() to work with proc_open() pipes on Windows
(PeekNamedPipe fix). This allows non-blocking check before reading stdout,
enabling true parallel test execution.

Author: dg

src/Runner/Job.php

@@ -11,7 +11,7 @@
 
 use Tester\Helpers;
 use function count, is_array, is_resource;
-use const DIRECTORY_SEPARATOR;
+use const DIRECTORY_SEPARATOR, PHP_OS_FAMILY, PHP_VERSION_ID;
 
 
 /**
@@ -130,7 +130,7 @@ public function run(bool $async = false): void
 			stream_set_blocking($this->stdout, enable: false); // on Windows does not work with proc_open()
 		} else {
 			while ($this->isRunning()) {
-				usleep(self::RunSleep); // stream_select() doesn't work with proc_open()
+				usleep(self::RunSleep);
 			}
 		}
 	}
@@ -145,7 +145,23 @@ public function isRunning(): bool
 			return false;
 		}
 
-		$this->test->stdout .= stream_get_contents($this->stdout);
+		// PHP 8.5+ Windows: stream_select() works with pipes (PeekNamedPipe fix),
+		if (PHP_OS_FAMILY === 'Windows' && PHP_VERSION_ID >= 80500) {
+			$read = [$this->stdout];
+			$w = $e = [];
+			while (@stream_select($read, $w, $e, 0, 0) > 0) {
+				$chunk = fread($this->stdout, 8192);
+				if ($chunk === false || $chunk === '') {
+					break;
+				}
+				$this->test->stdout .= $chunk;
+				$read = [$this->stdout];
+			}
+		} else {
+			// Linux/macOS: stream_get_contents() works without blocking
+			// Windows < 8.5: blocks, but is necessary to prevent deadlock when output exceeds pipe buffer (~64KB)
+			$this->test->stdout .= stream_get_contents($this->stdout);
+		}
 
 		$status = proc_get_status($this->proc);
 		if ($status['running']) {
@@ -213,4 +229,23 @@ public function getDuration(): ?float
 			? $this->duration
 			: null;
 	}
+
+
+	/**
+	 * Waits for activity on any of the running jobs.
+	 * @param  self[]  $jobs
+	 */
+	public static function waitForActivity(array $jobs): void
+	{
+		if (PHP_OS_FAMILY === 'Windows' && PHP_VERSION_ID < 80500) {
+			usleep(self::RunSleep);
+			return;
+		}
+
+		$streams = array_filter(array_map(fn($job) => $job->stdout, $jobs));
+		if ($streams) {
+			$w = $e = [];
+			@stream_select($streams, $w, $e, 0, self::RunSleep);
+		}
+	}
 }

src/Runner/Runner.php

@@ -115,7 +115,7 @@ public function run(): bool
 				}
 
 				if ($async) {
-					usleep(Job::RunSleep); // stream_select() doesn't work with proc_open()
+					Job::waitForActivity($running);
 				}
 
 				foreach ($running as $key => $job) {