add timeout on global & task config

Author: devfeel

config.go

@@ -16,6 +16,7 @@ type (
 		Global struct {
 			LogPath string `xml:"logpath,attr"  yaml:"logpath"`
 			IsRun   bool   `xml:"isrun,attr" yaml:"isrun"`
+			Timeout int64  `xml:"timeout,attr" yaml:"timeout"` //全局超时配置，单位为毫秒
 		} `xml:"global" yaml:"global"`
 
 		Tasks []struct {
@@ -28,6 +29,7 @@ type (
 			QueueSize   int64  `xml:"queuesize,attr" yaml:"queuesize"`     //queue类型下,queue初始长度
 			HandlerName string `xml:"handlername,attr" yaml:"handlername"` //Task对应的HandlerName,需使用RegisterHandler进行统一注册
 			HandlerData string `xml:"handlerdata,attr" yaml:"handlerdata"` //Task对应的自定义数据,可在配置源中设置
+			Timeout     int64  `xml:"timeout,attr" yaml:"timeout"`         //全局超时配置，单位为毫秒
 		} `xml:"tasks>task" yaml:"tasks"`
 	}
 

example/loadfromconfig/main.go

@@ -33,6 +33,7 @@ func main() {
 
 	//step 3: load config file
 	service.LoadFileConfig("c:/gotmp/dottask/task.conf")
+	fmt.Println(*service.Config)
 
 	fmt.Println(time.Now().String(), " => Begin Task")
 	//step 4: start all task

example/loadfromconfig/task.conf

@@ -1,8 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<config>
-<global isrun="true" logpath="d:/"/>
-<tasks>
-    <task taskid="Loop_Config "type="loop" isrun="true" duetime="1000" interval="1000" handlername="Loop_Config"></task>
-    <task taskid="Job_Config" type="cron" isrun="true" express="0 */5 * * * *" handlername="Job_Config"></task>
-</tasks>
-</config>
+         <config>
+         <global isrun="true" logpath="d:/" timeout="10000"/>
+         <tasks>
+             <task taskid="Loop_Config "type="loop" isrun="true" duetime="1000" interval="1000" handlername="Loop_Config"></task>
+             <task taskid="Job_Config" type="cron" isrun="true" express="0 */5 * * * *" handlername="Job_Config"></task>
+         </tasks>
+         </config>