add comments for process pool

src/process/src/Annotation/Mapping/Process.php

@@ -28,7 +28,7 @@
 class Process
 {
     /**
-     * Default
+     * Default run the first worker
      */
     public const DEFAULT = -1;
 

src/process/src/AutoLoader.php

@@ -43,7 +43,8 @@ public function beans(): array
                 'on'    => [
                     SwooleEvent::WORKER_START => bean(WorkerStartListener::class),
                     SwooleEvent::WORKER_STOP  => bean(WorkerStopListener::class)
-                ]
+                ],
+                'workerNum' => 2,
             ]
         ];
     }

src/process/src/Contract/MessageInterface.php

@@ -0,0 +1,27 @@
+<?php declare(strict_types=1);
+/**
+ * This file is part of Swoft.
+ *
+ * @link     https://swoft.org
+ * @document https://swoft.org/docs
+ * @contact  [email protected]
+ * @license  https://github.com/swoft-cloud/swoft/blob/master/LICENSE
+ */
+
+namespace Swoft\Process\Contract;
+
+use Swoole\Process\Pool;
+
+/**
+ * Class MessageInterface
+ *
+ * @since 2.0
+ */
+interface MessageInterface
+{
+    /**
+     * @param Pool   $pool
+     * @param string $data
+     */
+    public function onMessage(Pool $pool, string $data): void;
+}

src/process/src/ProcessDispatcher.php

@@ -64,8 +64,8 @@ public function dispatcher(Pool $pool, int $workerId): void
     private function getProcess(int $workerId): ProcessInterface
     {
         $processName = ProcessRegister::getProcess($workerId);
-        $process     = BeanFactory::getBean($processName);
 
+        $process = BeanFactory::getBean($processName);
         if (!$process instanceof ProcessInterface) {
             throw new ProcessException('Process must be instanceof ProcessInterface');
         }

src/process/src/SwooleEvent.php

@@ -12,6 +12,7 @@
 
 use Swoft\Process\Contract\WorkerStartInterface;
 use Swoft\Process\Contract\WorkerStopInterface;
+use Swoft\Process\Contract\MessageInterface;
 
 /**
  * Class SwooleEvent
@@ -30,11 +31,17 @@ class SwooleEvent
      */
     public const WORKER_STOP = 'workerStop';
 
+    /**
+     * On message
+     */
+    public const MESSAGE = 'message';
+
     /**
      * Listener mapping
      */
     public const LISTENER_MAPPING = [
         self::WORKER_START => WorkerStartInterface::class,
-        self::WORKER_STOP  => WorkerStopInterface::class
+        self::WORKER_STOP  => WorkerStopInterface::class,
+        self::MESSAGE      => MessageInterface::class
     ];
 }