本文主要研究一下xxl-job-executor-go的Task
//任务
type Task struct {
Id int64
Name string
Ext context.Context
Param *RunReq
fn TaskFunc
Cancel context.CancelFunc
StartTime int64
EndTime int64
//日志
log Logger
}
type TaskFunc func(cxt context.Context, param *RunReq) string
Task定义了Id、Name、Ext、Param、fn、Cancel、StartTime、EndTime、log属性
func (t *Task) Run(callback func(code int64, msg string)) {
defer func(cancel func()) {
if err := recover(); err != nil {
t.log.Info(t.Info()+" panic: %v", err)
debug.PrintStack() //堆栈跟踪
callback(500, "task panic:"+fmt.Sprintf("%v", err))
cancel()
}
}(t.Cancel)
msg := t.fn(t.Ext, t.Param)
callback(200, msg)
return
}
Run方法注册了defer在panic的时候执行callback和cancel,然后执行t.fn(t.Ext, t.Param)以及callback(200, msg)
func (t *Task) Info() string {
return "任务ID[" + Int64ToStr(t.Id) + "]任务名称[" + t.Name + "]参数:" + t.Param.ExecutorParams
}
Info方法返回了任务ID、任务名称、参数信息
xxl-job-executor-go的Task定义了Id、Name、Ext、Param、fn、Cancel、StartTime、EndTime、log属性;它提供了Run、Info方法。
大家好,我是民工哥。 一提到监控系统,大家很快就能想到 Zabbix 、 Prometheu s...
复制代码 代码如下: html !--混合框架的布局: 要想实现复杂的页面布局,只需在f...
一、前言 在了解加密原理前,我们来看看这样一个故事。 小红和小明是情侣,一天...
创业公司常常能给我们带来惊喜,不拘一格的工作方式,别开生面的商业模式,独树...
首先提示,处于安全的需要JavaScript不能直接访问本地资源文件,那怎么办呢?下...
用什么代码实现?不允许有白色底色产生,因为手机高度不一样 设计图要标准(750...
em是何物? em指字体高,任意浏览器的默认字体高都是16px。所以未经调整的浏览器...
问题描述 按钮样式为图标+文字,在使用flex布局写垂直居中时,iphone7手机上文字...
1. 给logo添加替代文本 这样有两个好处:屏幕阅读器能识别logo图片代表的含义,...
最近在开发中遇到的需求是:微信扫描课件二维码,播放其对应的课件视频 设计流程...