如何强制quartz.net作业完成

Question

后重新启动INTERVALL我有一个项目，我用TopShelf和TopShelf.Quartz

继this example我建设我的工作与

   s.ScheduleQuartzJob(q => 
        q.WithJob(() => JobBuilder.Create<MyJob>().Build()) 
        .AddTrigger(() => TriggerBuilder.Create() 
         .WithSimpleSchedule(builder => builder 
          .WithIntervalInSeconds(5) 
          .RepeatForever()) 
         .Build()) 
       ); 

这触发我的工作即使前一次仍在运行，每五秒钟一次。我真正想做的是开始一项工作，完成后等待五秒钟，然后重新开始。这是可能的还是我必须实现我自己的逻辑（例如通过一个静态变量）。

Answer 1

JobListener解决方案是一种强大且灵活的方式，可在完成后重新安排工作。感谢Nate Kerkhofs和stuartd的意见。

在我来说，因为我没有我的工作，不同的情况下，它足以来装饰我的工作类与DisallowConcurrentExecution属性

[DisallowConcurrentExecution] 
public class MyJob : IJob 
{ 
} 

FYI：使用JobListerener与TopShelf.Quartz的代码看起来是这样的

var jobName = "MyJob"; 
var jobKey = new JobKey(jobName); 

s.ScheduleQuartzJob(q => 
      q.WithJob(() => JobBuilder.Create<MyJob>() 
       .WithIdentity(jobKey).Build()) 
      .AddTrigger(() => TriggerBuilder.Create() 
       .WithSimpleSchedule(builder => builder 
        .WithIntervalInSeconds(5) 
       .Build()) 

var listener = new RepeatAfterCompletionJobListener(TimeSpan.FromSeconds(5)); 
var listenerManager = ScheduleJobServiceConfiguratorExtensions 
     .SchedulerFactory().ListenerManager; 
listenerManager.AddJobListener(listener, KeyMatcher<JobKey>.KeyEquals(jobKey)); 

如果您正在使用TopShelf.Quartz.Ninject（像我一样），不要忘了打电话之前UseQuartzNinject()调用ScheduleJobServiceConfiguratorExtensions.SchedulerFactory()

Answer 2

您可以使用TriggerListener（http://www.quartz-scheduler.net/documentation/quartz-2.x/tutorial/trigger-and-job-listeners.html）来侦听触发器何时结束，然后在5秒内重新安排时间。

另一种选择是将下一个作业安排为作业执行本身的最终操作。

http://www.quartz-scheduler.net/documentation/faq.html有一个问题，在某种程度上2/3下降，解释更多关于它。

Answer 3

提议@NateKerkhofs会的工作，这样的工作听众：

public class RepeatAfterCompletionJobListener : IJobListener 
{ 
    private readonly TimeSpan interval; 

    public RepeatAfterCompletionJobListener(TimeSpan interval) 
    { 
     this.interval = interval; 
    } 

    public void JobExecutionVetoed(IJobExecutionContext context) 
    { 
    } 

    public void JobToBeExecuted(IJobExecutionContext context) 
    { 
    } 

    public void JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException) 
    { 
     string triggerKey = context.JobDetail.Key.Name + ".trigger"; 

     var trigger = TriggerBuilder.Create() 
       .WithIdentity(triggerKey) 
       .StartAt(new DateTimeOffset(DateTime.UtcNow.Add(interval))) 
       .Build(); 

     context.Scheduler.RescheduleJob(new TriggerKey(triggerKey), trigger); 
    } 

    public string Name 
    { 
     get 
     { 
      return "RepeatAfterCompletionJobListener"; 
     } 
    } 
} 

然后将监听器添加到调度：

var jobKey = "myJobKey"; 
var schedule = new StdSchedulerFactory().GetScheduler(); 
listener = new 
    RepeatAfterCompletionJobListener(TimeSpan.FromSeconds(5)); 

schedule.ListenerManager.AddJobListener 
     (listener, KeyMatcher<JobKey>.KeyEquals(new JobKey(jobKey))); 

var job = JobBuilder.Create(MyJob) 
       .WithIdentity(jobKey) 
       .Build(); 

// Schedule the job to start in 5 seconds to give the service time to initialise 
var trigger = TriggerBuilder.Create() 
       .WithIdentity(CreateTriggerKey(jobKey)) 
       .StartAt(DateTimeOffset.Now.AddSeconds(5)) 
       .Build(); 

schedule.ScheduleJob(job, trigger); 

不幸的是，我不知道如何做到这一点（或者如果它可以完成）与Typshelf.Quartz库使用的流畅语法，我用TopShelf和常规Quartz.Net。