Merge pull request #7 from toplan/dev

add new feature: destroy task

README.md

@@ -13,7 +13,7 @@ lightweight and powerful task load balancing for php
 # Install
 
 ```php
-    composer require 'toplan/task-balancer:~0.4.1'
+    composer require 'toplan/task-balancer:~0.4.2'
 ```
 
 # Usage
@@ -179,7 +179,7 @@ get data value of task instance.
 | beforeCreateDriver | $task, $preReturn, $index, $handlers | no effect |
 | afterCreateDriver | $task, $preReturn, $index, $handlers | no effect |
 | beforeRun | $task, $preReturn, $index, $handlers | if `false` will stop run task and return `false` |
-| beforeDriverRun | $task, $driver, $preReturn, $index, $handlers | if `false` will stop run current driver and try to use next backup driver |
+| beforeDriverRun | $task, $driver, $preReturn, $index, $handlers | if `false` will stop to use current driver and try to use next backup driver |
 | afterDriverRun | $task, $driverResult, $preReturn, $index, $handlers | no effect |
 | afterRun | $task, $taskResult, $preReturn, $index, $handlers | if not boolean will override result value |
 

composer.json

@@ -2,7 +2,7 @@
   "name": "toplan/task-balancer",
   "description": "lightweight and powerful task load balancing for php (like the nginx load balancing)",
   "license": "MIT",
-  "version": "0.4.1",
+  "version": "0.4.2",
   "keywords": ["task", "balance", "load balancing", "balancer"],
   "authors": [
     {

src/TaskBalancer/Balancer.php

@@ -98,4 +98,21 @@ public static function getTask($name)
             return self::$tasks[$name];
         }
     }
+
+    /**
+     * destroy a task.
+     *
+     * @param $name
+     */
+    public static function destroy($name)
+    {
+        if (is_array($name)) {
+            foreach ($name as $v) {
+                self::destroy($v);
+            }
+        } elseif (is_string($name) && self::hasTask($name)) {
+            self::$tasks[$name] = null;
+            unset(self::$tasks[$name]);
+        }
+    }
 }

src/TaskBalancer/Task.php

@@ -227,7 +227,7 @@ public function runDriver($name)
         // before run a driver, call 'beforeDriverRun' hooks,
         // but current driver value is already change to this driver.
         // If 'beforeDriverRun' hook return false,
-        // will stop use current driver and try to use next driver
+        // will stop to use current driver and try to use next driver
         $currentDriverEnable = $this->callHookHandler('beforeDriverRun', $driver);
         if (!$currentDriverEnable) {
             return $this->tryNextDriver();
@@ -483,6 +483,9 @@ public function reset()
     {
         $this->status = null;
         $this->results = null;
+        $this->currentDriver = null;
+        $this->time['started_at'] = 0;
+        $this->time['finished_at'] = 0;
 
         return $this;
     }