如何在Quartz.net中的Interrupt方法中访问IJobexecutionContext

本文关键字：方法 访问 IJobexecutionContext Interrupt 中的 Quartz net | 更新日期: 2023-09-27 18:20:34

我目前正在开发基于Quartz.net的作业管理器。我希望能够实时显示作业执行状态，这样当发出作业中断请求时，我可以将context.JobDetail.JobDataMap.Put("status", "interrupting");保存在作业数据图中，并通过在调度器中获取所有当前执行的作业来读取此状态。但是，问题是，在Interrupt()方法中，我无法直接访问IJobExecutionContext上下文对象，因此我无法在请求中断时立即设置中断状态。这是我基本上想要实现的功能：

class InterruptedException : Exception { }
[PersistJobDataAfterExecution, DisallowConcurrentExecution]
class MyJob : IInterruptableJob
{
    private bool _interrupted;
    private void AssertContinue()
    {
        if (_interrupted) throw new InterruptedException();
    }
    public void Execute(IJobExecutionContext context)
    {
        try
        {
            context.JobDetail.JobDataMap.Put("status", "started");
            AssertContinue();
            // Do the work
            AssertContinue();
            context.JobDetail.JobDataMap.Put("status", "completed");
        }
        catch (InterruptedException)
        {
            // Set interrupted status when job is actually interrupted
            context.JobDetail.JobDataMap.Put("status", "interrupted");
        }
        catch
        {
            // log any othe errors but set interrupted status only on InterruptedException
        }
    }
    public void Interrupt()
    {
        _interrupted = true;
        // I want to set interrupting statues here!!!
        context.JobDetail.JobDataMap.Put("status", "interrupting");
    }
}

据我所知，IInterruptableJob接口实现的基本思想是在void Interrupt()方法中将一些_interrupted标志值设置为true，然后在Execute()方法中的每个执行步骤上检查该标志值。所以，基本上，我们不能立即中断作业，我们可以发出中断请求，只有在执行中断状态检查时，我们才能通过抛出异常来中断作业但我想在这段短时间内为我的工作设置中断状态。我该怎么做？在Interrupt()方法中是否可以得到IJobExecutionContext context对象

如何在Quartz.net中的Interrupt方法中访问IJobexecutionContext

事实证明，解决方案非常明显且简单。我只需要创建私人

IJobExecutionContext _context = null;

字段，并在Execute()方法中将其值设置为context。

public void Execute(IJobExecutionContext context) 
{
    _context = context;
    ...
}

基本上，我们只能中断正在执行的作业，因此如果调用Interrupt()，则至少调用Execute()一次，因此这种方法基本上适合我的需求，并在调用Interrupt后立即更新作业的DataMap。

相关文章：