我的应用程序与Binance相关，我使用Binance.Net（来自JKopf）作为API Package 器，并在某些时间间隔内使用Hangfire进行cron作业任务。
我必须执行三种类型的任务：

• cron作业任务在完成的蜡烛（为所有蜡烛之前的最后一个）.例如，这些在下一个小时开始时执行，例如。晚上11：00，延迟1秒，因为币安有时会延迟数据。
• 使用网络套接字的真实的时间检查。基本上，他们的API只为最后一支蜡烛提供了一个流，因为它是唯一一个改变的，这是很明显的。
• 当满足条件时，在10分钟后执行计划任务。看看PerformInRealTimeLogicAsync和isTriggered。当isTriggered为true时，它应该在10分钟后安排另一次检查。如果到一小时结束时还剩下不到10分钟，它应该在最后一分钟执行检查。例如，假设当前时间是10：52 pm，这意味着没有10分钟了。它应该在下一个小时（10：59 pm）之前的最后一分钟执行检查。如果第二个10分钟检查返回false，它应该在另一个10分钟后安排另一个任务。

主要问题是Web套接字逻辑（Web套接字）延迟，即。它没有按时执行，而是有一些延迟，并且 *10分钟后 * 逻辑不能正常工作。
问题：
1.在结束前1分钟执行检查的逻辑，当没有10分钟时，不起作用。
1.就像我上面说的，整个逻辑在某种程度上是延迟的。可能是await Task.Delay(1000)，我不确定。
我知道这是延迟，因为它有时会忘记执行某些分钟。

Current time: 12/6/2019 12:41:00 AM
// note that there isn't 12:42:00, it forgot to execute it
Current time: 12/6/2019 12:43:00 AM

1.目前，我订阅了cron作业（DoWork()）中的web套接字，我认为这就是延迟的问题。是在cron作业之外订阅并在应用程序停止之前取消订阅的正确方法。

/ Start a cron job on each hour
RecurringJob.AddOrUpdate("task{i}", () => DoWork(), "0 */1 * * *", TimeZoneInfo.Local);
await _socketClient.Unsubscribe(_subscription);

public void DoWork()
{
    ...

    // That delay is needed because Binance sometimes delays the new candles
    await Task.Delay(1000);

    var klines = await _binanceService.GetAllKlinesAsync();

    // Web sockets
    await PerformInRealTimeLogicAsync();

    ...
}

// Web sockets
private bool _isProcessing = false;

public void async Task PerformInRealTimeLogicAsync()
{
    var result = await _socketClient.SubscribeToKlineUpdatesAsync(symbol, interval, async data =>
    {
        if (!_isProcessing && Data?.Data.Close != data.Data.Close)
        {
            _isProcessing = true;
            Data = data;

            // First logic
            var result = await FirstLogicAsync();
            if (result)
            {
                _isProcessing = false;
                return;
            }

            // Second logic
            var isTriggered = await SecondLogicAsync();
            if (isTriggered)
            {
                // Wait 10 minutes and check again same condition
                double seconds = RemainingSecondsUntilNextHour();
                if (seconds <= 10 * 60)
                {
                    BackgroundJob.Schedule(() => DelayedJob(), TimeSpan.FromSeconds(seconds - (1 * 60)));
                }
                else
                {
                    BackgroundJob.Schedule(() => DelayedJob(), TimeSpan.FromMinutes(10));
                }

                _isProcessing = false;
                return;
            }

            _isProcessing = false;
        }
    });

    if (result.Success)
    {
        _subscription = result.Data;
    }
}

private double RemainingSecondsUntilNextHour()
{
    var timeOfDay = DateTime.Now.TimeOfDay;
    var nextFullHour = TimeSpan.FromHours(Math.Ceiling(timeOfDay.TotalHours));
    var delta = (nextFullHour - timeOfDay).TotalSeconds;
    return delta;
}

// Scheduled job
public void DelayedJob()
{
    if (condition)
    {
        // Conditions are met, so we stop
    }
    else
    {
        // Conditions are not met, so we schedule another job after another 10 minutes
        double seconds = RemainingSecondsUntilNextHour();
        if (seconds <= 10 * 60)
        {
            BackgroundJob.Schedule(() => DelayedJob(), TimeSpan.FromSeconds(seconds - (1 * 60)));
        }
        else
        {
            BackgroundJob.Schedule(() => DelayedJob(), TimeSpan.FromMinutes(10));
        }
    }
}

**编辑：**问题是我总是在每个时间间隔调用DoWork()方法订阅流，我从来没有取消订阅。我应该在最后一分钟取消订阅吗？

请注意，我仍然没有修复它，我只是意识到这是原因之一。