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

Question

我必须每分钟运行一个 C# 方法。我确实创建了一个observablefor 计时器并每 1 分钟调用一次，我在类构造函数中使用了这段代码。还有其他解决方案吗？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();

}