如何创建调度程序（例如调度推文或 API 请求）

Question

我有一个日程项目表，它们可能被安排在同一时间。我想知道如何让它们在正确的时间执行：

我看到的问题是执行一个计划项目（如计划的 Twitter 帖子）需要一个 API 请求，该请求可能需要一两秒 - 可能更长。如果我按顺序执行它们+同时有太多计划项目，则它们的执行时间可能会晚于计划时间。

我将如何构建这个避免这些问题的“调度”系统？有什么提示、建议吗？

谢谢！

Answer 1

我将使用 Windows 服务来完成此任务。然后应使用BackgroundWorker 进程异步安排每个项目。这将允许所有计划的进程快速异步启动，这样它们就不会发生冲突，也不依赖于启动前完成的前一个进程。

Answer 2

您可能需要考虑 Quartz.NET。在调度和任务执行方面为您提供了很大的灵活性。

Answer 3

除非您采取措施利用所有 IO 操作都存在的异步 API，否则唯一的方法就是使用多个线程。请考虑 .net ThreadPool，因为当排队的工作项过多时，这会增加线程数量。这里会有一个限制，因为线程池旋转额外线程的速度相对较慢。在持续过载的情况下，您的系统会发出呻吟声。正如我所说，解决此问题的最佳方法是使用异步 IO。

Answer 4

当您希望任务运行时，您可以将它们放入线程中：

public abstract class MyTask {
    public abstract void DoWork();
}


// ...

public void SomeTaskStarter()
{
    MyTask task = SomeFactoryMethodToCreateATaskInstance();

    new Thread(new ThreadStart(task.DoWork)).Start();
}

MyTask 是一个抽象类，它代表要执行的任务，它定义了一个方法 DoWork() 来执行您想要的操作。 SomeFactoryMethodToCreateATaskInstance() 将构造一个任务的具体实例，您所需要做的就是编写 DoWork() 来完成您需要做的事情：

public class Twitterer : MyTask
{
    private string _tweet;
    public Twitterer(string tweet)
    {
        _tweet = tweet;
    }
    public override DoWork()
    {
        TwitterApi api = new TwitterApi(); // whatever
        api.PostTweet(tweet);
    }
}

您肯定会想要某种任务完成操作。无论您做什么，任务完成例程都应该是线程安全的，并且如果您需要执行任何 UI 风格的工作，则可能应该通过 BeginInvoke()/EndInvoke() 调用。

SomeTaskStarter() 最好从 Windows 服务调用，并且很可能包含一个参数，其中包含有关应启动哪个任务等信息。