你会如何改变用C#编写的Heartbeat进程？

Question

我正在考虑实施一个"心跳"过程,以便在一天中完成大量重复的清理任务.

这似乎是使用Command模式的好机会,所以我有一个看起来像这样的界面:

   public interface ICommand
   {
       void Execute();
       bool IsReady();
   }

然后我创建了几个我想要运行的任务.这是一个基本的例子:

public class ProcessFilesCommand : ICommand
{
    private int secondsDelay;
    private DateTime? lastRunTime;

    public ProcessFilesCommand(int secondsDelay)
    {
        this.secondsDelay = secondsDelay;
    }

    public void Execute()
    {
        Console.WriteLine("Processing Pending Files...");
        Thread.Sleep(5000); // Simulate long running task
        lastRunTime = DateTime.Now;
    }

    public bool IsReady()
    {
        if (lastRunTime == null) return true;

        TimeSpan timeSinceLastRun = DateTime.Now.Subtract(lastRunTime.Value);
        return (timeSinceLastRun.TotalSeconds > secondsDelay);
    }

}

最后,我的控制台应用程序在此循环中运行,寻找要添加到ThreadPool的等待任务:

class Program
{
    static void Main(string[] args)
    {

        bool running = true;

        Queue<ICommand> taskList = new Queue<ICommand>();
        taskList.Enqueue(new ProcessFilesCommand(60)); // 1 minute interval
        taskList.Enqueue(new DeleteOrphanedFilesCommand(300)); // 5 minute interval

        while (running)
        {
            ICommand currentTask = taskList.Dequeue();
            if (currentTask.IsReady())
            {
                ThreadPool.QueueUserWorkItem(t => currentTask.Execute());
            }
            taskList.Enqueue(currentTask);
            Thread.Sleep(100);
        }

    }
}

除了我在操作系统课上做的一些工作之外,我没有太多的多线程经验.但是,据我所知,我的线程都没有访问任何共享状态,因此它们应该没问题.

对于我想做的事情,这看起来像是一个"OK"设计吗？你有什么改变吗？

Answer 1

这是一个很好的开始.我们最近做了很多这样的事情,所以我可以提供一些建议.

1. 不要将线程池用于长时间运行的任务.线程池旨在运行许多小任务.如果您正在执行长时间运行的任务,请使用单独的线程.如果你让线程池饿死(用完所有任务),排队的所有东西都会等待线程池线程变得可用,从而显着影响线程池的有效性能.

2. 让Main()例程跟踪事情的运行时间和下一次运行的时间.而不是每个命令说"是的我准备好了"或"不是我不是"对于每个命令都是相同的,只需要具有LastRun和Interval字段,然后Main()可以用来确定每个命令何时需要运行.

3. 不要使用队列.虽然它看起来像是一个Queue类型的操作,但由于每个命令都有自己的间隔,所以它实际上不是一个普通的Queue.而是将所有命令放在List中,然后按最短时间对列表进行排序.睡眠线程,直到需要运行第一个命令.运行该命令.按下一个命令运行列表.睡觉.重复.

4. 不要使用多个线程.如果每个命令的间隔是一分钟或几分钟,您可能根本不需要使用线程.您可以通过在同一个线程上执行所有操作来简化.

5. 错误处理.这种事情需要广泛的错误处理,以确保一个命令中的问题不会使整个循环失败,因此您可以在问题发生时进行调试.您还可能想要确定一个命令是否应该在出现错误时立即重试,或者等到下一次计划运行,或者甚至比正常延迟更多.如果每次都发生错误,您可能还希望不在命令中记录错误(经常运行的命令中的错误很容易创建大量日志文件).

Answer 2

您可以选择使用为您处理所有调度和线程的框架来构建应用程序,而不是从头开始编写所有内容.开源库NCron正是为此目的而设计的,并且非常易于使用.

像这样定义你的工作:

class MyFirstJob : CronJob
{
    public override void Execute()
    {
        // Put your logic here.
    }
}

并为您的应用程序创建一个主要入口点,包括这样的计划设置:

class Program
{
    static void Main(string[] args)
    {
        Bootstrap.Init(args, ServiceSetup);
    }

    static void ServiceSetup(SchedulingService service)
    {
        service.Hourly().Run<MyFirstJob>();
        service.Daily().Run<MySecondJob>();
    }
}

如果您选择沿着这条路走下去,这就是您需要编写的所有代码.如果需要,您还可以选择执行更复杂的计划或依赖项注入,并且包含开箱即用的日志记录.

免责声明:我是NCron的首席程序员,所以我可能只是有点偏见!;-)