mirror of https://github.com/ouqiang/gocron
任务执行前后添加日志
parent
bf07c6e2e2
commit
7c3f6a58d4
2
build.sh
2
build.sh
|
@ -4,7 +4,7 @@
|
|||
# 构建应用, 生成压缩包 gocron.zip或gocron.tar.gz
|
||||
# ./build.sh -p windows -a amd64
|
||||
# 参数含义
|
||||
# -p 指定平台(widows|linux|darwin)
|
||||
# -p 指定平台(windows|linux|darwin)
|
||||
# -a 指定体系架构(amd64|386), 默认amd64
|
||||
|
||||
|
||||
|
|
|
@ -129,7 +129,10 @@ func shutdown() {
|
|||
// 停止所有任务调度
|
||||
serviceTask.StopAll()
|
||||
taskNumInRunning := service.TaskNum.Num()
|
||||
logger.Infof("正在运行的任务有%d个, 等待所有任务执行完成后退出", taskNumInRunning)
|
||||
logger.Infof("正在运行的任务有%d个", taskNumInRunning)
|
||||
if taskNumInRunning > 0 {
|
||||
logger.Info("等待所有任务执行完成后退出")
|
||||
}
|
||||
for {
|
||||
if taskNumInRunning <= 0 {
|
||||
break
|
||||
|
|
|
@ -274,7 +274,9 @@ func createJob(taskModel models.TaskHost) cron.FuncJob {
|
|||
if taskLogId <= 0 {
|
||||
return
|
||||
}
|
||||
logger.Infof("开始执行任务#%s#命令-%s", taskModel.Task.Name, taskModel.Command)
|
||||
taskResult := execJob(handler, taskModel)
|
||||
logger.Infof("任务完成#%s#命令-%s", taskModel.Task.Name, taskModel.Command)
|
||||
afterExecJob(taskModel, taskResult, taskLogId)
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue