#### Version 0.8.5

* New feature: add support auto register queue task from config
* 2019-06-14 15:00

Author: devfeel

config.go

@@ -3,10 +3,10 @@ package task
 import (
 	"encoding/json"
 	"encoding/xml"
+	"gopkg.in/yaml.v2"
 	"io/ioutil"
 	"os"
 	"path/filepath"
-	"gopkg.in/yaml.v2"
 )
 
 type (
@@ -25,6 +25,7 @@ type (
 			DueTime     int64  `xml:"duetime,attr" yaml:"duetime"` //开始任务的延迟时间（以毫秒为单位），如果<=0则不延迟
 			Interval    int64  `xml:"interval,attr" yaml:"interval"`
 			Express     string `xml:"express,attr" yaml:"express"`
+			QueueSize   int64  `xml:"queuesize,attr" yaml:"queuesize"`
 			HandlerName string `xml:"handlername,attr" yaml:"handlername"`
 			HandlerData string `xml:"handlerdata,attr" yaml:"handlerdata"`
 		} `xml:"tasks>task" yaml:"tasks"`

example/loadfromconfig/main.go

@@ -32,14 +32,15 @@ func main() {
 	RegisterTask(service)
 
 	//step 3: load config file
-	service.LoadConfig("d:/gotmp/task/task.conf")
+	service.LoadConfig("d:/gotmp/dottask/task.conf")
 
 	fmt.Println(time.Now().String(), " => Begin Task")
 	//step 4: start all task
 	service.StartAllTask()
 
 	fmt.Println(service.PrintAllCronTask())
 
-	for true {
+	for {
+		time.Sleep(time.Hour)
 	}
 }

tasks.go

@@ -17,8 +17,8 @@ const (
 )
 
 const (
-	TaskType_Loop = "loop"
-	TaskType_Cron = "cron"
+	TaskType_Loop  = "loop"
+	TaskType_Cron  = "cron"
 	TaskType_Queue = "queue"
 )
 
@@ -40,8 +40,6 @@ type (
 		Reset(conf *TaskConfig) error
 	}
 
-
-
 	ExceptionHandleFunc func(*TaskContext, error)
 
 	//task 容器
@@ -127,6 +125,13 @@ func (service *TaskService) LoadConfig(configFile string, confType ...interface{
 				} else {
 					service.Logger().Debug("CreateLoopTask success [" + fmt.Sprint(v) + "]")
 				}
+			} else if v.TaskType == TaskType_Queue && v.Interval > 0 {
+				_, err := service.CreateQueueTask(v.TaskID, v.IsRun, v.Interval, handler, v, v.QueueSize)
+				if err != nil {
+					service.Logger().Warn("CreateQueueTask failed [" + err.Error() + "] [" + fmt.Sprint(v) + "]")
+				} else {
+					service.Logger().Debug("CreateQueueTask success [" + fmt.Sprint(v) + "]")
+				}
 			} else {
 				service.Logger().Warn("CreateTask failed not match config [" + fmt.Sprint(v) + "]")
 			}
@@ -226,7 +231,7 @@ func (service *TaskService) CreateLoopTask(taskID string, isRun bool, dueTime in
 }
 
 // CreateQueueTask create new queuetask
-func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, taskData interface{}, queueSize int) (Task, error){
+func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval int64, handler TaskHandle, taskData interface{}, queueSize int64) (Task, error) {
 	context := new(TaskContext)
 	context.TaskID = taskID
 	context.TaskData = taskData
@@ -246,8 +251,6 @@ func (service *TaskService) CreateQueueTask(taskID string, isRun bool, interval
 	return task, nil
 }
 
-
-
 // GetTask get TaskInfo by TaskID
 func (service *TaskService) GetTask(taskID string) (t Task, exists bool) {
 	service.taskMutex.RLock()
@@ -288,13 +291,11 @@ func (service *TaskService) PrintAllCronTask() string {
 	return body
 }
 
-
 // GetAllTasks get all tasks
 func (service *TaskService) GetAllTasks() map[string]Task {
 	return service.taskMap
 }
 
-
 // RemoveAllTask remove all task
 func (service *TaskService) RemoveAllTask() {
 	service.StopAllTask()

version.MD

@@ -1,5 +1,9 @@
 ## devfeel/task
 
+#### Version 0.8.5
+* New feature: add support auto register queue task from config
+* 2019-06-14 15:00
+
 #### Version 0.8.4
 * Bug Fixed: Auto restart task when task's app code panic error, if no auto restart, the goroutine will be stop
 * 2018-09-20 22:00