蕙兰瑜伽视频,儿童节的作文,苏利浦
作为一个优秀的开源调度框架,quartz 具有以下特点:
另外,作为 spring 默认的调度框架,quartz 很容易与 spring 集成实现灵活可配置的调度功能。
quartz调度核心元素:
我这里简单记录使用过程及代码:
1:首先引用quartz组件
2:using quartz;using quartz.impl;
注:在本地新建一个控制台项目,将以下代码copy过去即可用,只需要重写execute方法即可。quartz3.0及以上的版本是采用的异步,3.0以下的版本没有采用异步,使用方法是一样的
主函数入口文件:
using backgroundtask.job;
using log4net;
using quartz;
using quartz.impl;
using system;
using system.collections.generic;
using system.linq;
using system.text;
using system.threading.tasks;
namespace backgroundtask
{
class program
{
private static readonly ilog _log = logmanager.getlogger(typeof(program));
private static readonly string tiggername = "testjobtrigger";
private static readonly string gropname = "testjobtriggergrop";
private static readonly string jobname = "testjob";
//从工厂中获取一个调度器实例化
private static ischeduler scheduler = null;
static void main(string[] args)
{
console.writeline("开始任务....");
_log.debug("开始任务....");
start();
}
private static async void start()
{
//从工厂中获取一个调度器实例化
scheduler = await stdschedulerfactory.getdefaultscheduler();
await scheduler.start();
//创建一个作业
ijobdetail job1 = jobbuilder.create<testjob>()
.withidentity(jobname, gropname)
.usingjobdata("key","value")// 传递参数 在execute方法中获取(以什么类型值传入,取值就用相应的类型方法取值)
.build();
// 创建触发器
itrigger trigger1 = triggerbuilder.create()
.withidentity(tiggername, gropname)
.startnow() //现在开始
.withsimpleschedule(x => x //触发时间,10秒一次。
.withintervalinseconds(10)
.repeatforever()) //不间断重复执行
.build();
await scheduler.schedulejob(job1, trigger1); //把作业,触发器加入调度器。
console.readkey();
// 清除任务和触发器
clearjobtrigger();
}
/// <summary>
/// 清除任务和触发器
/// </summary>
private static void clearjobtrigger()
{
triggerkey triggerkey = new triggerkey(tiggername, gropname);
jobkey jobkey = new jobkey(jobname, gropname);
if (scheduler != null)
{
scheduler.pausetrigger(triggerkey);
scheduler.unschedulejob(triggerkey);
scheduler.deletejob(jobkey);
scheduler.shutdown();// 关闭
}
}
}
}
实现ijob 接口的任务文件
using log4net;
using quartz;
using system;
using system.collections.generic;
using system.linq;
using system.text;
using system.threading.tasks;
namespace backgroundtask.job
{
public class testjob : ijob
{
private readonly ilog _log = logmanager.getlogger(typeof(testjob));
/// <summary>
/// 测试作业
/// </summary>
/// <param name="context"></param>
/// <returns></returns>
public async task execute(ijobexecutioncontext context)
{
jobdatamap datamap = context.jobdetail.jobdatamap;
string k = datamap.getstring("key");//获取参数(可根据传递的类型使用getint、getfloat、getstring.....)
_log.debug("run testjob debug");
_log.error("run testjob error");
_log.info("run testjob info");
// 在这里处理你的任务
}
}
}
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
asp.net搭建博客,使用BlogEngine.NET+MySql搭建博客
网友评论