PHPBench (#8)

* Benchmark

* Add limit set

* Bench react http client

composer.json

@@ -33,6 +33,7 @@
         "friendsofphp/php-cs-fixer": "^3.15",
         "guzzlehttp/guzzle": "^7.5",
         "jenky/atlas": "^0.5",
+        "phpbench/phpbench": "^1.2",
         "phpstan/phpstan": "^1.10",
         "phpunit/phpunit": "^9.0",
         "react/async": "^4.1",
@@ -53,6 +54,9 @@
         "analyse": [
             "vendor/bin/phpstan analyse"
         ],
+        "bench": [
+            "./vendor/bin/phpbench run --report=aggregate"
+        ],
         "cs": [
             "vendor/bin/php-cs-fixer fix"
         ],

phpbench.json

@@ -0,0 +1,6 @@
+{
+    "$schema":"./vendor/phpbench/phpbench/phpbench.schema.json",
+    "runner.bootstrap": "vendor/autoload.php",
+    "runner.path": "tests/Benchmark",
+    "runner.file_pattern": "*Bench.php"
+}

tests/Benchmark/BenchTrait.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Fansipan\Peak\Tests\Benchmark;
+
+trait BenchTrait
+{
+    public function provideLimits(): \Generator
+    {
+        yield '50 rqs' => ['limit' => 50];
+        yield '100 rqs' => ['limit' => 100];
+        yield '200 rqs' => ['limit' => 200];
+    }
+}

tests/Benchmark/DefaultBench.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Fansipan\Peak\Tests\Benchmark;
+
+use Fansipan\Peak\Tests\TestRequestTrait;
+use GuzzleHttp\Client;
+use GuzzleHttp\Pool;
+use GuzzleHttp\RequestOptions;
+use PhpBench\Attributes\ParamProviders;
+
+final class DefaultBench
+{
+    use BenchTrait;
+    use TestRequestTrait;
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchGuzzlePool(array $params): void
+    {
+        $options = [
+            RequestOptions::ALLOW_REDIRECTS => false,
+            RequestOptions::HTTP_ERRORS => false,
+        ];
+
+        Pool::batch(new Client($options), $this->createPsrRequests($params['limit']));
+    }
+}

tests/Benchmark/PslBench.php

@@ -0,0 +1,34 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Fansipan\Peak\Tests\Benchmark;
+
+use Fansipan\Peak\Client\GuzzleClient;
+use Fansipan\Peak\Client\SymfonyClient;
+use Fansipan\Peak\Concurrency\PslDeferred;
+use Fansipan\Peak\PoolFactory;
+use Fansipan\Peak\Tests\TestRequestTrait;
+use PhpBench\Attributes\ParamProviders;
+
+final class PslBench
+{
+    use BenchTrait;
+    use TestRequestTrait;
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchPslPoolUsingGuzzle(array $params): void
+    {
+        PoolFactory::createFromClient(
+            new GuzzleClient(new PslDeferred())
+        )->send($this->createPsrRequests($params['limit']));
+    }
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchPslPoolUsingSymfony(array $params): void
+    {
+        PoolFactory::createFromClient(
+            new SymfonyClient(new PslDeferred())
+        )->send($this->createPsrRequests($params['limit']));
+    }
+}

tests/Benchmark/ReactBench.php

@@ -0,0 +1,42 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Fansipan\Peak\Tests\Benchmark;
+
+use Fansipan\Peak\Client\GuzzleClient;
+use Fansipan\Peak\Client\ReactClient;
+use Fansipan\Peak\Client\SymfonyClient;
+use Fansipan\Peak\Concurrency\ReactDeferred;
+use Fansipan\Peak\PoolFactory;
+use Fansipan\Peak\Tests\TestRequestTrait;
+use PhpBench\Attributes\ParamProviders;
+
+final class ReactBench
+{
+    use BenchTrait;
+    use TestRequestTrait;
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchReactPoolUsingGuzzle(array $params): void
+    {
+        PoolFactory::createFromClient(
+            new GuzzleClient(new ReactDeferred())
+        )->send($this->createPsrRequests($params['limit']));
+    }
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchReactPoolUsingSymfony(array $params): void
+    {
+        PoolFactory::createFromClient(
+            new SymfonyClient(new ReactDeferred())
+        )->send($this->createPsrRequests($params['limit']));
+    }
+
+    #[ParamProviders(['provideLimits'])]
+    public function benchReactPoolUsingHttpClient(array $params): void
+    {
+        PoolFactory::createFromClient(new ReactClient())
+            ->send($this->createPsrRequests($params['limit']));
+    }
+}