eson/imitater
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

添加task的初始化接口

Browse Source
This commit is contained in:
huangsimin 2018-12-18 14:38:59 +08:00
parent 8f68634adc
commit 8aa804db7f
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
person.go
View File

@ -14,6 +14,7 @@ import (
// ITask 继承这个接口的类 // ITask 继承这个接口的类
type ITask interface { type ITask interface {
Execute(data interface{}) ITask Execute(data interface{}) ITask
Init()
SetCrontab(cron string) SetCrontab(cron string)
SetLastStatus(status bool) SetLastStatus(status bool)
@ -154,6 +155,8 @@ func (person *Person) Execute() {
// initTask 生成一个新任务 // initTask 生成一个新任务
func initTask(conf *Config, task ITask, curl *curl2info.CURL) { func initTask(conf *Config, task ITask, curl *curl2info.CURL) {
task.Init()
if curl.Crontab != "" { if curl.Crontab != "" {
task.SetCrontab(curl.Crontab) task.SetCrontab(curl.Crontab)
} else { } else {

5
task.go
View File

@ -22,6 +22,11 @@ type Task struct {
proxies clinked.CircularLinked proxies clinked.CircularLinked
} }
// Init 初始化, 会被Persion默认调用, 可以用来覆盖
func (task *Task) Init() {
}
// SetName 任务的名字 // SetName 任务的名字
func (task *Task) SetName(name string) { func (task *Task) SetName(name string) {
task.name = name task.name = name