c# - 可靠的任务计划

Question

好吧...请原谅我提出了如此模糊的问题，但我因此而崩溃，我找不到一个好的逻辑来实现它，或者至少找不到一个为我做这种事情的好库。

情况

我的应用程序应该在不同的时间间隔内执行很多任务，其中一些需要在满足某些条件或其他方法完成后执行等等。[把它想象成一个方法依赖树]......我想知道在像巨大的在线游戏或这样的项目这样的大项目中，他们如何组织他们的代码以便在错误的时间或没有崩溃或执行某些方法满足它的条件？

问题

整个问题是在我的应用程序中我想要以下规格

• 能够安排方法在指定时间运行。
• 能够暂停、取消、停止甚至重复一项任务。
• 能够在另一个任务完成之前不执行特定任务，因此我可以创建某种流。
• 能够创建某种 Flow 以确保某些方法在其父方法或过程方法完成之前永远不会执行。
• 所有这一切都以一种有条理、流畅而强大的方式进行。

Answer 1

反应式扩展（Rx.NET）可能会完成这项工作！http://msdn.microsoft.com/en-us/data/gg577609.aspx

例子：

此示例安排任务执行。

Console.WriteLine("Current time: {0}", DateTime.Now);

// Start event 30 seconds from now.
IObservable<long> observable = Observable.Timer(TimeSpan.FromSeconds(30));

// Token for cancelation
CancellationTokenSource source = new CancellationTokenSource();

// Create task to execute.
Task task = new Task(() => Console.WriteLine("Action started at: {0}", DateTime.Now));

// Subscribe the obserable to the task on execution.
observable.Subscribe(x => task.Start(), source.Token);

// If you want to cancel the task do: 
//source.Cancel();

 Console.WriteLine("Press any key to exit");
 Console.ReadKey();

结果：

示例 2：

每 x 秒重复一次任务。

Console.WriteLine("Current time: {0}", DateTime.Now);

// Repeat every 2 seconds.
IObservable<long> observable = Observable.Interval(TimeSpan.FromSeconds(2));

// Token for cancelation
CancellationTokenSource source = new CancellationTokenSource();

// Create task to execute.
Action action = (() => Console.WriteLine("Action started at: {0}", DateTime.Now));

// Subscribe the obserable to the task on execution.
observable.Subscribe(x => { Task task = new Task(action);task.Start(); },source.Token);

// If you want to cancel the task do: 
//source.Cancel();
Console.WriteLine("Press any key to exit");
Console.ReadKey();

结果：

示例任务继续：

Console.WriteLine("Current time: {0}", DateTime.Now);

        // Repeat every 2 seconds.
        IObservable<long> observable = Observable.Interval(TimeSpan.FromSeconds(2));

        // Token for cancelation
        CancellationTokenSource source = new CancellationTokenSource();

        // Create task to execute.
        Action action = (() => Console.WriteLine("Action started at: {0}", DateTime.Now));
        Action resumeAction = (() => Console.WriteLine("Second action started at {0}", DateTime.Now));

        // Subscribe the obserable to the task on execution.
        observable.Subscribe(x => { Task task = new Task(action); task.Start();
                                      task.ContinueWith(c => resumeAction());
        }, source.Token);

        // If you want to cancel the task do: 
        //source.Cancel();
        Console.WriteLine("Press any key to exit");
        Console.ReadKey();

结果：