#### Version 0.9.4

* feature: 新增CreateTask用于根据TaskConfig对象创建对应的Task
* Opt: 新增ErrNotSupportTaskType异常变量
* About CreateTask：
    - Define: CreateTask(config TaskConfig) (Task, error)
    - 支持cron\loop\queue三类Task的创建
    - 定义错误的Task类型时将返回ErrNotSupportTaskType
* Opt: 整理代码格式
* 2020-01-04 09:00 at ShangHai

Author: devfeel

example/queuetask/main.go

@@ -7,7 +7,8 @@ import (
 )
 
 var service *TaskService
-const(
+
+const (
 	taskName = "TestQueue"
 )
 
@@ -21,7 +22,7 @@ func Job_DealMessage(ctx *TaskContext) error {
 }
 
 func enqueeMessage() {
-	for i:=0;i<100;i++ {
+	for i := 0; i < 100; i++ {
 		t, exists := service.GetTask(taskName)
 		if exists {
 			qTask := t.(*QueueTask)
@@ -40,7 +41,7 @@ func main() {
 	qTask, err := service.CreateQueueTask(taskName, true, 1, Job_DealMessage, nil, DefaultQueueSize)
 	if err != nil {
 		fmt.Println("service.CreateQueueTask error! => ", err.Error())
-	}else{
+	} else {
 		fmt.Println("service.CreateQueueTask success! => ", qTask.TaskID())
 	}
 
@@ -53,7 +54,7 @@ func main() {
 		err = t.RunOnce()
 		if err != nil {
 			fmt.Println(t.Context(), "RunOnce error =>", err)
-		}else{
+		} else {
 			fmt.Println(t.Context(), "RunOnce success")
 		}
 	}
@@ -63,20 +64,21 @@ func main() {
 	t, exists = service.GetTask(taskName)
 	if exists {
 		conf := &TaskConfig{
-			IsRun:   true,
-			Interval:1000,
+			IsRun:    true,
+			Interval: 1000,
 		}
 		err = t.Reset(conf)
 		if err != nil {
 			fmt.Println(t, "Reset error =>", err)
-		}else{
+		} else {
 			fmt.Println(t, "Reset success ")
 		}
 	}
 
 	go enqueeMessage()
 
-	for true {
+	for {
+		time.Sleep(time.Hour)
 	}
 
 }

express_test.go

@@ -1,10 +1,10 @@
 package task
 
 import (
-	"testing"
 	"fmt"
+	"testing"
 )
 
-func TestParseExpress(t *testing.T){
+func TestParseExpress(t *testing.T) {
 	fmt.Println(parseExpress("1-5", ExpressType_WeekDay))
-}
+}

tasks.go

@@ -2,6 +2,7 @@ package task
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"os"
 	"runtime/debug"
@@ -32,6 +33,8 @@ const (
 	fullTimeLayout         = "2006-01-02 15:04:05.9999"
 )
 
+var ErrNotSupportTaskType = errors.New("not support task type")
+
 type (
 	Task interface {
 		TaskID() string
@@ -211,6 +214,18 @@ func (service *TaskService) Logger() Logger {
 	return service.logger
 }
 
+// CreateTask create new task with TaskConfig and register to task service
+func (service *TaskService) CreateTask(config TaskConfig) (Task, error) {
+	if config.TaskType == TaskType_Cron {
+		return service.CreateCronTask(config.TaskID, config.IsRun, config.Express, config.Handler, config.TaskData)
+	} else if config.TaskType == TaskType_Loop {
+		return service.CreateLoopTask(config.TaskID, config.IsRun, config.DueTime, config.Interval, config.Handler, config.TaskData)
+	} else if config.TaskType == TaskType_Loop {
+		return service.CreateLoopTask(config.TaskID, config.IsRun, config.DueTime, config.Interval, config.Handler, config.TaskData)
+	}
+	return nil, ErrNotSupportTaskType
+}
+
 // CreateCronTask create new cron task and register to task service
 func (service *TaskService) CreateCronTask(taskID string, isRun bool, express string, handler TaskHandle, taskData interface{}) (Task, error) {
 	task, err := NewCronTask(taskID, isRun, express, handler, taskData)

version.MD

@@ -1,5 +1,15 @@
 ## devfeel/dottask
 
+#### Version 0.9.4
+* feature: 新增CreateTask用于根据TaskConfig对象创建对应的Task
+* Opt: 新增ErrNotSupportTaskType异常变量
+* About CreateTask：
+    - Define: CreateTask(config TaskConfig) (Task, error)
+    - 支持cron\loop\queue三类Task的创建
+    - 定义错误的Task类型时将返回ErrNotSupportTaskType
+* Opt: 整理代码格式
+* 2020-01-04 09:00 at ShangHai
+
 #### Version 0.9.3
 * Opt: 完善config模块，优化config注入模式
 * Opt: 增加ConfigHandle函数定义,用于应用自定义config加载实现(如从redis\mysql等源读取配置)