没有 Task.Delay，Quartz 作业无法执行答案

【问题标题】：Quartz job not execute without Task.Delay没有 Task.Delay，Quartz 作业无法执行
【发布时间】：2021-10-26 02:44:27
【问题描述】：

这是我的工作：

public class MyJob: IJob
{
        public static bool run = true;

        public Task Execute(IJobExecutionContext context)
        {
            logger.Info("Start MyJob");
        }
}

这是我的课程：

 
        private static ILogger logger = LogManager.GetCurrentClassLogger();
        private static IJob MyJob;
        
        static void Main(string[] args)
        {
            try
            {
                logger.Info("Start");


                RunProgram().GetAwaiter().GetResult();
                logger.Info("Completed");
            }
            catch (Exception ex)
            {
                logger.Error($"error");
            }
        }

        private static async Task RunProgram()
        {
            try
            {
                ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
                IScheduler scheduler = await schedulerFactory.GetScheduler();

                IJobDetail job = JobBuilder.Create<MyJob>()
                    .WithIdentity("job1", "group1")
                    .Build();
                
                ITrigger trigger = TriggerBuilder.Create()
                    .WithIdentity("trigger1", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(5)
                        .RepeatForever())
                    .Build();

                await scheduler.ScheduleJob(job, trigger);


                await scheduler.Start();
                await Task.Delay(TimeSpan.FromSeconds(10));


                await scheduler.Shutdown();
                
                
            }
            catch (SchedulerException se)
            {
                await Console.Error.WriteLineAsync(se.ToString());
            }
        }

上面的代码正在运行。

触发器集 MyJob 每 5 秒运行一次。 Task.Delay() 使程序在 10 秒后终止。所以 MyJob 会被执行两次。

我想等到工作完成而不是设置计时器，所以我阅读了石英教程并像这样修改 RunProgram()：

        private static async Task RunProgram()
        {
            try
            {
                ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
                IScheduler scheduler = await schedulerFactory.GetScheduler();
                await scheduler.Start();                                           //++

                IJobDetail job = JobBuilder.Create<MyJob>()
                    .WithIdentity("job1", "group1")
                    .Build();

                ITrigger trigger = TriggerBuilder.Create()
                    .WithIdentity("trigger1", "group1")
                    .StartNow()
                    .WithSimpleSchedule(x => x
                        .WithIntervalInSeconds(5)
                        .RepeatForever())
                    .Build();

                await scheduler.ScheduleJob(job, trigger);

                //--await scheduler.Start();
                //--await Task.Delay(TimeSpan.FromSeconds(10))
                //--await scheduler.Shutdown();

            }
            catch (SchedulerException se)
            {
                await Console.Error.WriteLineAsync(se.ToString());
            }
        }

那么 MyJob 永远不会被执行。

有什么问题吗？

【问题讨论】：

标签： c# quartz-scheduler quartz.net quartz

【解决方案1】：

您好，您可以尝试删除 StartNow()。从下面的代码

       ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(5)
                    .RepeatForever())
                .Build();

另外，请尝试使用 here 中提到的 crone 触发器。

【讨论】：

感谢您的回答。我尝试删除 StartNow() 但没有任何反应。而且 CronTrigger 甚至无法处理我的原始代码。

【解决方案2】：

只需在 Main 方法中添加 Console.ReadLine() 即可。这将防止您的申请被终止。

static void Main(string[] args)
{
    try
    {
        logger.Info("Start");


        RunProgram().GetAwaiter().GetResult();
         logger.Info("Completed");

        Console.ReadLine();
    }
    catch (Exception ex)
    {
        logger.Error($"error");
    }
}

可以找到更好的解决方案here

【讨论】：

感谢您的回答。这仍然不能阻止作业被终止
有了这个解决方案和你的 RunProgram() 的第二个版本，我的任务每 5 秒执行一次。我相信你在问别的东西。也许你的工作需要超过 5 秒？请澄清。
是的，我的工作需要超过 5 秒。问题是我什至无法用我的第二版 RunProgram() 解雇我的工作。