Add sync task demo

swoft-cloud · Jul 16, 2019 · ec938e5 · ec938e5
1 parent b5dab89
commit ec938e5
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 12 deletions.
diff --git a/src/task/src/Swoole/SyncFinishListener.php b/src/task/src/Swoole/SyncFinishListener.php
diff --git a/src/task/src/Swoole/SyncTaskListener.php b/src/task/src/Swoole/SyncTaskListener.php
@@ -29,6 +29,8 @@ class SyncTaskListener implements SyncTaskInterface
     private $dispatcher;
 
     /**
+     * Dispatch
+     *
      * @param Server $server
      * @param int    $taskId
      * @param int    $srcWorkerId
@@ -39,6 +41,7 @@ class SyncTaskListener implements SyncTaskInterface
      */
     public function onTask(Server $server, $taskId, int $srcWorkerId, $data)
     {
+        // Task params
         [$type, $name, $method, $params, $ext] = Packet::unpack($data);
 
         return $this->dispatcher->dispatch($type, $name, $method, $params, $ext);

diff --git a/src/task/src/SyncTaskDispatcher.php b/src/task/src/SyncTaskDispatcher.php
@@ -23,6 +23,8 @@
 class SyncTaskDispatcher
 {
     /**
+     * Dispatch
+     *
      * @param string $type
      * @param string $name
      * @param string $method
@@ -45,6 +47,8 @@ public function dispatch(string $type, string $name, string $method, array $para
     }
 
     /**
+     * Handle task
+     *
      * @param string $name
      * @param string $method
      * @param array  $params
@@ -72,7 +76,7 @@ private function handle(string $name, string $method, array $params)
         $object = BeanFactory::getBean($className);
         if (!method_exists($object, $methodName)) {
             throw new TaskException(
-                sprintf('Task(name=%s method=%s) is not exist!', $name, $method)
+                sprintf('Task(name=%s method=%s) method is not exist!', $name, $method)
             );
         }
 

diff --git a/src/task/src/TaskDispatcher.php b/src/task/src/TaskDispatcher.php
@@ -74,7 +74,7 @@ private function handle(Request $request)
         $object = BeanFactory::getBean($className);
         if (!method_exists($object, $methodName)) {
             throw new TaskException(
-                sprintf('Task(name=%s method=%s) is not exist!', $name, $method)
+                sprintf('Task(name=%s method=%s) method is not exist!', $name, $method)
             );
         }