我在使用 Quartz 时遇到以下问题工作数据图。我希望使用简单的石英时Job并传递非原始对象(例如字符串生成器) into 工作日期图, 方法execute(来自我的工作)应该始终使用我放置的反对对象的不同副本来调用。不幸的是我总是得到我放入的对象的实例工作日期图(就像它是一个 StatefulJob 一样)。
在下面的示例中,我希望在每次调用中都会得到一个“*”,而每次都会得到一个以上的“*”。
public class MyJob implements Job {
public static void main(String[] args) throws SchedulerException {
SchedulerFactory schedFact = new StdSchedulerFactory();
Scheduler sched = schedFact.getScheduler();
JobDetail jobDetail = new JobDetail("job", Scheduler.DEFAULT_GROUP, MyJob.class);
jobDetail.getJobDataMap().put("param", new StringBuilder());
Trigger trigger = TriggerUtils.makeImmediateTrigger("trigger", 10, 100);
trigger.setGroup(Scheduler.DEFAULT_GROUP);
sched.scheduleJob(jobDetail, trigger);
sched.start();
try {
Thread.sleep(1000L);
} catch (Exception e) {}
sched.shutdown(true);
}
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
StringBuilder sb = (StringBuilder) context.getMergedJobDataMap().get("param");
sb.append("*");
System.out.println(sb.toString());
}
}
我想,我遗漏了一些关于 Quartz 工作原理的信息。有人知道是什么吗?
Quartz 中还有其他功能可以让您以更优化的方式传递非基元。查看 SchedulerContext 类的功能。
using System;
using System.Text;
using Quartz;
using Quartz.Impl;
namespace QuartzNET.Samples
{
class Program
{
static void Main(string[] args)
{
// Create RAMJobStore instance
DirectSchedulerFactory.Instance.CreateVolatileScheduler(1);
ISchedulerFactory factory = DirectSchedulerFactory.Instance;
// Get scheduler and add object
IScheduler scheduler = factory.GetScheduler();
scheduler.Context.Add("History", new StringBuilder("Runtime History: "));
// Create job and trigger
IJobDetail job = JobBuilder.Create<MyJob>()
.WithIdentity("MyJob")
.Build();
ITrigger trigger = TriggerBuilder.Create()
.WithIdentity("Trigger")
.StartNow()
.WithSimpleSchedule(x => x
.WithInterval(TimeSpan.FromMinutes(1))
.RepeatForever())
.Build();
// Run it all
scheduler.Start();
scheduler.ScheduleJob(job, trigger);
}
}
class MyJob : IJob
{
public void Execute(IJobExecutionContext context)
{
var history = context.Scheduler.Context["History"] as StringBuilder;
history.AppendLine(context.NextFireTimeUtc.ToString());
Console.WriteLine(context.NextFireTimeUtc);
}
}
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)