public/gin-vue-admin
1
0
Fork 0
mirror of https://github.com/flipped-aurora/gin-vue-admin.git synced 2026-09-21 12:32:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

自动插件模式鉴定调整 (#1161)

Browse Source 
* fix: #1160

* 自动插件模式鉴定调整

Co-authored-by: songzhibin97 <718428482@qq.com>
This commit is contained in:
奇淼（piexlmax
2022-07-09 14:27:04 +08:00
committed by GitHub
co-authored by songzhibin97
parent d6c6f39387
commit d52d909171
6 changed files with 115 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/utils/timer/timed_task.go
+6 -6
View File
@@ -7,8 +7,8 @@ import (
)
type Timer interface {
AddTaskByFunc(taskName string, spec string, task func()) (cron.EntryID, error)
AddTaskByJob(taskName string, spec string, job interface{ Run() }) (cron.EntryID, error)
AddTaskByFunc(taskName string, spec string, task func(), option ...cron.Option) (cron.EntryID, error)
AddTaskByJob(taskName string, spec string, job interface{ Run() }, option ...cron.Option) (cron.EntryID, error)
FindCron(taskName string) (*cron.Cron, bool)
StartTask(taskName string)
StopTask(taskName string)
@@ -24,11 +24,11 @@ type timer struct {
}
// AddTaskByFunc 通过函数的方法添加任务
func (t *timer) AddTaskByFunc(taskName string, spec string, task func()) (cron.EntryID, error) {
func (t *timer) AddTaskByFunc(taskName string, spec string, task func(), option ...cron.Option) (cron.EntryID, error) {
t.Lock()
defer t.Unlock()
if _, ok := t.taskList[taskName]; !ok {
t.taskList[taskName] = cron.New(cron.WithSeconds())
t.taskList[taskName] = cron.New(option...)
}
id, err := t.taskList[taskName].AddFunc(spec, task)
t.taskList[taskName].Start()
@@ -36,11 +36,11 @@ func (t *timer) AddTaskByFunc(taskName string, spec string, task func()) (cron.E
}
// AddTaskByJob 通过接口的方法添加任务
func (t *timer) AddTaskByJob(taskName string, spec string, job interface{ Run() }) (cron.EntryID, error) {
func (t *timer) AddTaskByJob(taskName string, spec string, job interface{ Run() }, option ...cron.Option) (cron.EntryID, error) {
t.Lock()
defer t.Unlock()
if _, ok := t.taskList[taskName]; !ok {
t.taskList[taskName] = cron.New()
t.taskList[taskName] = cron.New(option...)
}
id, err := t.taskList[taskName].AddJob(spec, job)
t.taskList[taskName].Start()