Scheduler
大约 1 分钟
Scheduler
任务调度任务标识
参数说明
参数 | 类型 | 必须 | 默认 | 说明 |
---|---|---|---|---|
value | String | 否 | "" | 设置任务名,这个名字,如果不指定,就会默认用 bean 的 name |
使用说明
注解到任务调度的任务类上,来标识这是一个可以执行的任务
示例
@Slf4j
@Scheduler("clearExpires")
public class ClearExpiresTask extends RedisScheduledTaskJob {
final ISysUserOnlineService sysUserOnlineService;
@Resource
private IMessageSendService messageSendService;
@Override
protected Consumer<JSONObject> getLogRecorder() {
return json -> messageSendService.send(new ScheduledLogDTO(json));
}
public ClearExpiresTask(RedisTemplate<String, String> redisTemplate
, Environment env
, ISysUserOnlineService sysUserOnlineService) {
super(redisTemplate, env);
this.sysUserOnlineService = sysUserOnlineService;
}
@Override
public void run(Map<String, Object> params) {
log.debug("clearExpires => 当前线程名称 {} ", Thread.currentThread().getName());
log.debug(">>>>>> 清理检查在线用户状态开始 >>>>>> ");
sysUserOnlineService.clearExpires();
log.debug(">>>>>> 清理检查在线用户状态结束 >>>>>> ");
}
}