Rename process

src/Fork.php

@@ -66,10 +66,10 @@ public function run(callable ...$callables): array
             $tasks[] = Task::fromCallable($callable, $order);
         }
 
-        return $this->waitFor(...$tasks);
+        return $this->runTasks(...$tasks);
     }
 
-    protected function waitFor(Task ...$queue): array
+    public function runTasks(Task ...$queue): array
     {
         $output = [];
 
@@ -123,6 +123,10 @@ protected function forkForTask(Task $task): Task
 
         $processId = pcntl_fork();
 
+        if ($task->name()) {
+            cli_set_process_title($task->name());
+        }
+
         if ($this->currentlyInChildTask($processId)) {
             $socketToChild->close();
 

src/Task.php

@@ -9,7 +9,7 @@ class Task
 {
     protected const SERIALIZATION_TOKEN = '[[serialized::';
 
-    protected string $name;
+    protected string $name = '';
 
     protected int $order;
 

tests/ForkTest.php

@@ -2,6 +2,7 @@
 
 use Carbon\Carbon;
 use Spatie\Fork\Fork;
+use Spatie\Fork\Task;
 
 it('will execute the given closures')
     ->expect(
@@ -138,3 +139,24 @@ function () {
             fn () => 1
         );
 });
+
+
+it('custom process name', function () {
+    $tasks = [];
+
+    for ($order = 0; $order < 3; $order++) {
+        $taskName = "Async Process Name. Index: $order";
+
+        $task = Task::fromCallable(fn () => cli_get_process_title() === $taskName, $order);
+        $task->setName($taskName);
+
+        $tasks[] = $task;
+    }
+
+    $result = Fork::new()
+        ->runTasks(...$tasks);
+
+    expect($result[0])->toEqual(true)
+        ->and($result[1])->toEqual(true)
+        ->and($result[2])->toEqual(true);
+});