c# - 在 .NET 4 中，如何使用 Rx 的 IScheduler.SchedulePeriodic 方法允许取消正在运行的工作

Question

我想使用 Rx 中的 IScheduler.SchedulePeriodic 方法定期运行一些工作。我希望能够通过允许工作接受 CancellationToken 在处理从 SchedulePeriodic 返回的 IDisposable 时取消，不仅可以在执行之间取消工作，还可以在工作运行时(合作地)取消工作。

在工作取消之前，IDisposable 的处置不应该阻塞，只是为工作在下一次机会取消自身提供机会。

我如何在 .NET 4.0 中使用 Rx 来做到这一点？

它看起来像 cooperative cancellation support added in Rx 2 (请参阅“使调度程序更易于使用 'await'”部分)可能对此有所帮助，但它在 .NET 4 中不可用。

Answer 1

这是我想出的扩展方法:

public static IDisposable SchedulePeriodic(
    this IScheduler scheduler,
    TimeSpan interval,
    Action<CancellationToken> work) {

    if (scheduler == null) {
        throw new ArgumentNullException("scheduler");
    }
    if (work == null) {
        throw new ArgumentNullException("work");
    }

    var cancellationDisposable = new CancellationDisposable();

    var subscription = scheduler.SchedulePeriodic(
        interval,
        () => {
            try {
                work(cancellationDisposable.Token);
            } catch (OperationCanceledException e) {
                if (e.CancellationToken != cancellationDisposable.Token) {
                    // Something other than the token we passed in threw this exception
                    throw;
                }
            }
        });

    return new CompositeDisposable(cancellationDisposable, subscription);
}