Async

Author: teodoroleckie

src/Async.php

@@ -11,28 +11,28 @@
 class Async
 {
     /** @var TaskInterface[] */
-    private array $pendingQueue = [];
+    protected array $pendingQueue = [];
 
     /** @var TaskInterface[] */
-    private array $progressQueue = [];
+    protected array $progressQueue = [];
 
     /** @var TaskInterface[] */
-    private array $finishedQueue = [];
+    protected array $finishedQueue = [];
 
     /** @var TaskInterface[] */
-    private array $failedQueue = [];
+    protected array $failedQueue = [];
 
     /** @var TaskFactoryInterface */
-    private TaskFactoryInterface $taskFactory;
+    protected TaskFactoryInterface $taskFactory;
 
     /** @var Encoder */
-    private Encoder $encoder;
+    protected Encoder $encoder;
 
     /** @var mixed[] */
-    private array $results = [];
+    protected array $results = [];
 
     /** @var int */
-    private int $sleep;
+    protected int $sleep;
 
     /**
      * Async constructor.
@@ -44,7 +44,7 @@ class Async
     public function __construct(
         ?TaskFactoryInterface $taskFactory = null,
         ?Encoder $encoder = null,
-        ?int $sleep = 50
+        ?int $sleep = 5000
     ) {
         $this->taskFactory = $taskFactory ?? new TaskFactory();
         $this->encoder = $encoder ?? new Encoder();
@@ -53,7 +53,7 @@ public function __construct(
         $this->listener();
     }
 
-    private function listener(): void
+    protected function listener(): void
     {
         pcntl_async_signals(true);
         pcntl_signal(SIGCHLD, function ($signo, $status) {
@@ -79,7 +79,7 @@ private function listener(): void
      * @param TaskInterface $task
      * @return TaskInterface
      */
-    private function finished(TaskInterface $task): TaskInterface
+    protected function finished(TaskInterface $task): TaskInterface
     {
         unset($this->progressQueue[$task->pid()]);
 
@@ -92,7 +92,7 @@ private function finished(TaskInterface $task): TaskInterface
         return $task;
     }
 
-    private function notify(): void
+    protected function notify(): void
     {
         $process = array_shift($this->pendingQueue);
 
@@ -107,7 +107,7 @@ private function notify(): void
      * @param TaskInterface $task
      * @return TaskInterface
      */
-    private function progress(TaskInterface $task): TaskInterface
+    protected function progress(TaskInterface $task): TaskInterface
     {
         $task->start();
 
@@ -122,7 +122,7 @@ private function progress(TaskInterface $task): TaskInterface
      * @param TaskInterface $task
      * @return TaskInterface
      */
-    private function failed(TaskInterface $task): TaskInterface
+    protected function failed(TaskInterface $task): TaskInterface
     {
         unset($this->progressQueue[$task->pid()]);
 
@@ -148,7 +148,7 @@ public function add(callable $process): TaskInterface
      * @param TaskInterface $task
      * @return TaskInterface
      */
-    private function pending(TaskInterface $task): TaskInterface
+    protected function pending(TaskInterface $task): TaskInterface
     {
         $this->pendingQueue[$task->id()] = $task;
 

src/Task.php

@@ -103,7 +103,7 @@ public function output(): mixed
      * @param callable $callback
      * @param array    $arguments
      */
-    private function call(callable $callback, array $arguments): void
+    protected function call(callable $callback, array $arguments): void
     {
         call_user_func_array($callback, $arguments);
     }

src/TaskFactory.php

@@ -30,50 +30,25 @@ class TaskFactory implements TaskFactoryInterface
      */
     public function __construct()
     {
-        $this->findAutoload()
-            ->findScript();
+        $this->autoloader = $this->find('vendor/autoload.php');
+        $this->script = $this->find('bin/child');
     }
 
     /**
-     * @return $this
+     * @param string $file
+     * @return string|null
      */
-    private function findScript(): self
+    protected function find(string $file): ?string
     {
-        if (!$this->script) {
-            $paths = array_filter([
-                __DIR__ . '/../../../../bin/child',
-                __DIR__ . '/../../../bin/child',
-                __DIR__ . '/../../bin/child',
-                __DIR__ . '/../bin/child',
-                __DIR__ . '/bin/child',
-
-            ], static function (string $path) {
-                return file_exists($path);
-            });
-            $this->script = reset($paths);
-        }
-
-        return $this;
-    }
-
-    /**
-     * @return $this
-     */
-    private function findAutoload(): self
-    {
-        if (!$this->autoloader) {
-            $paths = array_filter([
-                __DIR__ . '/../../../../vendor/autoload.php',
-                __DIR__ . '/../../../vendor/autoload.php',
-                __DIR__ . '/../../vendor/autoload.php',
-                __DIR__ . '/../vendor/autoload.php',
-            ], static function (string $path) {
-                return file_exists($path);
-            });
-            $this->autoloader = reset($paths);
-        }
-
-        return $this;
+        $paths = array_filter([
+            __DIR__ . '/../../../../'.$file,
+            __DIR__ . '/../../../'.$file,
+            __DIR__ . '/../../'.$file,
+            __DIR__ . '/../'.$file,
+        ], static function (string $path) {
+            return file_exists($path);
+        });
+        return reset($paths);
     }
 
     /**
@@ -97,15 +72,15 @@ public function createTask(
     /**
      * @return string
      */
-    private function id(): string
+    protected function id(): string
     {
         return (++$this->index) . $this->pid();
     }
 
     /**
      * @return string
      */
-    private function pid(): string
+    protected function pid(): string
     {
         $this->pid = $this->pid ?? getmypid();