allow fork server in threads

Author: kpicaza

src/Child.php

@@ -0,0 +1,31 @@
+<?php
+
+
+namespace Antidot\React;
+
+class Child
+{
+    public static function fork(int $numberOfWorkers, callable $asyncServer, int $numberOfFork = 0): void
+    {
+        $pid = pcntl_fork();
+        if (-1 === $pid) {
+            // @fail
+            die('Fork failed');
+        }
+
+        if (0 === $pid) {
+            $asyncServer();
+            pcntl_waitpid($pid, $status);
+            return;
+        }
+
+        // @parent
+        $numberOfWorkers--;
+        ++$numberOfFork;
+        if ($numberOfWorkers > 0) {
+            self::fork($numberOfWorkers, $asyncServer, $numberOfFork);
+        }
+
+        pcntl_waitpid($pid, $status);
+    }
+}

src/Container/Config/ConfigProvider.php

@@ -24,7 +24,9 @@ public function __invoke(): array
                     Socket::class => SocketFactory::class,
                 ],
             ],
-            'server' => []
+            'server' => [
+                'workers' => 1
+            ]
         ];
     }
 }

src/PromiseResponse.php

@@ -4,10 +4,8 @@
 
 namespace Antidot\React;
 
-use Psr\Http\Message\ResponseInterface;
 use React\Promise\PromiseInterface;
 use RingCentral\Psr7\Response;
-use Throwable;
 
 class PromiseResponse extends Response implements PromiseInterface
 {

src/ServerFactory.php

@@ -6,7 +6,6 @@
 
 use Antidot\Application\Http\Application;
 use Psr\Container\ContainerInterface;
-use Psr\Http\Message\ResponseInterface;
 use Psr\Http\Message\ServerRequestInterface;
 use React\EventLoop\LoopInterface;
 use React\Http\Server;

src/SocketFactory.php

@@ -19,10 +19,10 @@ public function __invoke(ContainerInterface $container): Socket
         /** @var array<string, string|null> $config */
         $config = $globalConfig['server'];
 
-        return new Socket(sprintf(
-            '%s:%s',
-            $config['host'] ?? '0.0.0.0',
-            $config['port'] ?? '8080'
-        ), $loop);
+        return new Socket(
+            sprintf('%s:%s', $config['host'] ?? '0.0.0.0', $config['port'] ?? '8080'),
+            $loop,
+            ['tcp' => ['so_reuseport' => 2 <= $config['workers']]]
+        );
     }
 }