每分钟都会调用一些 C# 方法 (asp.net web api web)

Question

我必须每分钟运行一个 C# 方法。我确实为计时器创建了一个 observable 并每 1 分钟调用一次，我在 class 构造函数中使用了这段代码。还有其他解决办法吗？

public Test()
{
    IObservable<long> timer = Observable
        .Defer(() =>
    {
        var now = DateTimeOffset.Now;
        var result = new DateTimeOffset(now.Year, now.Month, now.Day, now.Hour, 0, 0, now.Offset);
        result = result.AddMinutes(((now.Minute / 1) + 1) * 1);
        return Observable.Timer(result, TimeSpan.FromMinutes(1.0));
    });

    timer.Subscribe(async x =>
    {
        await InvokeMethod().ConfigureAwait(false);
    });
}

Answer 1

在我看来，这就是您所需要的：

public void Test()
{
    IObservable<Unit> timer =
        Observable
            .Defer(() =>
            {
                var now = DateTimeOffset.Now;
                var result = new DateTimeOffset(now.Year, now.Month, now.Day, now.Hour, now.Minute + 1, 0, now.Offset);
                return Observable.Timer(result, TimeSpan.FromMinutes(1.0));
            })
            .SelectMany(x => Observable.FromAsync(() => InvokeMethod()));

    timer.Subscribe();
}

请记住，这会随着时间的推移而变化，不会在每一分钟触发。每次都需要重新调整。使用 Observable.Generate 会更好。

public void Test()
{
    IObservable<Unit> timer =
        Observable
            .Generate(
                new { now = DateTimeOffset.Now, count = 0 },
                t => true,
                t => new { t.now, count = t.count + 1 },
                t => t.count,
                t => t.now.AddMinutes(t.count))
            .SelectMany(x => Observable.FromAsync(() => InvokeMethod()));

    timer.Subscribe();
}

每分钟都会调用一些 C# 方法 (asp.net web api web)

every minute some C# method invoke (asp.net web api web)

c#

system.reactive