如何参数化C#中Quartz任务构建方法以提升灵活性？

问题背景 #

原本的调度任务创建方法针对固定的RepostTransactionsJob实现，现在需要将Job类型参数化为泛型，实现通用的任务创建逻辑，但修改后出现编译错误：

The type 'T' cannot be used as a type parameter 'T' in the generic type or method 'JobBuilder.Create()' There is no implicit reference conversion from 'T' to 'Quartz.IJob'

原固定类型代码 #

private async Task BuildJobs(int startHour, int endHour, int intervalOffsetSeconds = 0)
{
    try
    {
        var job = JobBuilder.Create<RepostTransactionsJob>()
            .WithIdentity(nameof(RepostTransactionsJob), TriggerGroup)
            .WithDescription("Reposting transactions")
            .Build();

        var trigger = TriggerBuilder.Create()
            .WithIdentity(string.Concat(nameof(RepostTransactionsJob), "-trigger"), TriggerGroup)
            .WithSchedule(CronScheduleBuilder.CronSchedule(string.Format("{2:ss} {2:mm} {0}-{1} ? * * *", startHour, endHour, TimeSpan.FromSeconds(intervalOffsetSeconds))))
            .Build();

        await this.scheduler.ScheduleJob(job, trigger);
    }
    catch (Exception ex)
    {
        this.logger.LogToLocal(ex.Message);
    }
}

尝试的泛型代码（存在编译错误） #

private async Task BuildJobs<T>(int startHour, int endHour, int intervalOffsetSeconds = 0) where T : class
{
    try
    {
        var jobName = typeof(T).Name;

        var job = JobBuilder.Create<T>()
            .WithIdentity(jobName, TriggerGroup)
            .WithDescription("Reposting transactions")
            .Build();

        var trigger = TriggerBuilder.Create()
            .WithIdentity(string.Concat(jobName, "-trigger"), TriggerGroup)
            .WithSchedule(CronScheduleBuilder.CronSchedule(string.Format("{2:ss} {2:mm} {0}-{1} ? * * *", startHour, endHour, TimeSpan.FromSeconds(intervalOffsetSeconds))))
            .Build();

        await this.scheduler.ScheduleJob(job, trigger);
    }
    catch (Exception ex)
    {
        this.logger.LogToLocal(ex.Message);
    }
}

解决方案 #

编译错误的核心原因是JobBuilder.Create<T>()要求泛型参数T必须实现Quartz.IJob接口，同时Quartz需要通过反射实例化Job对象，因此需要确保T具备公共无参构造函数。只需修改泛型约束即可解决：

修改后的泛型方法代码 #

private async Task BuildJobs<T>(int startHour, int endHour, int intervalOffsetSeconds = 0) where T : class, Quartz.IJob, new()
{
    try
    {
        var jobName = typeof(T).Name;

        var job = JobBuilder.Create<T>()
            .WithIdentity(jobName, TriggerGroup)
            .WithDescription("Reposting transactions")
            .Build();

        var trigger = TriggerBuilder.Create()
            .WithIdentity($"{jobName}-trigger", TriggerGroup)
            .WithSchedule(CronScheduleBuilder.CronSchedule($"{TimeSpan.FromSeconds(intervalOffsetSeconds):ss} {TimeSpan.FromSeconds(intervalOffsetSeconds):mm} {startHour}-{endHour} ? * * *"))
            .Build();

        await this.scheduler.ScheduleJob(job, trigger);
    }
    catch (Exception ex)
    {
        this.logger.LogToLocal(ex.Message);
    }
}

关键修改点 #

• 泛型约束更新为where T : class, Quartz.IJob, new()：
  • class：限定T为引用类型
  • Quartz.IJob：满足Quartz对Job类型的强制要求，确保T是合法的任务类型
  • new()：保证T拥有公共无参构造函数，Quartz需要以此实例化Job对象
• 额外优化：将string.Concat和string.Format替换为字符串插值，提升代码可读性

调用示例 #

// 调用时传入实现了IJob的任务类型即可
await BuildJobs<RepostTransactionsJob>(8, 18);

内容的提问来源于stack exchange，提问作者Bhav