Merge pull request #59 from reactphp-parallel/4.x-add-tests

[4.x] Add tests to test our tests

Author: WyriHaximus

composer.json

@@ -20,11 +20,19 @@
         "wyrihaximus/async-test-utilities": "^5 || ^7.2",
         "wyrihaximus/pool-info": "^1.1 || ^2.0"
     },
+    "require-dev": {
+        "react-parallel/runtime": "^3"
+    },
     "autoload": {
         "psr-4": {
             "ReactParallel\\Tests\\": "src/"
         }
     },
+    "autoload-dev": {
+        "psr-4": {
+            "ReactParallel\\Tests\\Tests\\": "tests/"
+        }
+    },
     "config": {
         "allow-plugins": {
             "dealerdirect/phpcodesniffer-composer-installer": true,

composer.lock

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ReactParallel\Tests\Tests;
+
+use ReactParallel\Contracts\PoolInterface;
+use ReactParallel\EventLoop\EventLoopBridge;
+use ReactParallel\Tests\AbstractPoolTest;
+
+final class AbstractPoolTestTest extends AbstractPoolTest
+{
+    protected function createPool(): PoolInterface
+    {
+        return new ImmidiatePool(new EventLoopBridge());
+    }
+}

tests/AbstractPoolTestTest.php

@@ -0,0 +1,79 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ReactParallel\Tests\Tests;
+
+use ReactParallel\Contracts\ClosedException;
+use ReactParallel\Contracts\PoolInterface;
+use ReactParallel\EventLoop\EventLoopBridge;
+use ReactParallel\Runtime\Runtime;
+use WyriHaximus\PoolInfo\Info;
+
+final class ImmidiatePool implements PoolInterface
+{
+    private int $activeThreads = 0;
+    private bool $closed = false;
+    /** @var array<Runtime> */
+    private array $runtimes = [];
+
+    public function __construct(private readonly EventLoopBridge $eventLoopBridge)
+    {
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function info(): iterable
+    {
+        yield Info::TOTAL => $this->activeThreads;
+        yield Info::BUSY => $this->activeThreads;
+        yield Info::CALLS => 0;
+        yield Info::IDLE  => 0;
+        yield Info::SIZE  => $this->activeThreads;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function run(\Closure $callable, array $args = []): mixed
+    {
+        if ($this->closed === true) {
+            throw ClosedException::create();
+        }
+
+        $runtime = Runtime::create($this->eventLoopBridge);
+        $this->runtimes[\spl_object_id($runtime)] = $runtime;
+        $this->activeThreads++;
+        try {
+            $result = $runtime->run($callable, $args);
+        } finally {
+            unset($this->runtimes[\spl_object_id($runtime)]);
+        }
+        $this->activeThreads--;
+
+        return $result;
+    }
+
+    public function close(): bool
+    {
+        $this->closed = true;
+
+        foreach ($this->runtimes as $runtime) {
+            $runtime->close();
+        }
+
+        return true;
+    }
+
+    public function kill(): bool
+    {
+        $this->closed = true;
+
+        foreach ($this->runtimes as $runtime) {
+            $runtime->kill();
+        }
+
+        return true;
+    }
+}