如何強制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。