.Net Core 中的长时间运行操作超时



如何为可能长时间运行的操作 lambda 实现超时?我尝试将操作包装在任务中,然后使用取消令牌强制执行超时,但无济于事。

    public void LongRunningTask()
    {
        ExecuteSafely(() => //do something );
    }
    private void ExecuteSafely(Action action)
    {
        try
        {
            action();
        }
        catch
        {
            // just don't crash 
        }
    }

根据第一个答案的新实现:

public void Information<T>(string messageTemplate, T propertyValue)
{
    ExecuteSafely(() => _logger.Information(messageTemplate, propertyValue));
}        
private void ExecuteSafely(Action action)
{
    try
    {
        var cts = new CancellationTokenSource();
        cts.CancelAfter(new TimeSpan(0, 0, 1));
        try
        {
            Task.Run(action, cts.Token).Wait();
        }
        catch (TaskCanceledException e)
        {
            System.Diagnostics.Debug.WriteLine(e.ToString());
            //here you know the task is cancelled due to timeout
        }
    }
    catch (Exception e)
    {
        System.Diagnostics.Debug.WriteLine(e.ToString());
        // just don't crash 
    }
}

这仅在我单步进入 Task.Run 时正常工作,但在我单步执行或让它运行时无法正常工作。也许将 lambda 传递到操作中存在一些闭包问题?

你应该使用 CancelTokenSource

    void Execute(Action action, TimeSpan timeout)
    {
        var cts = new CancellationTokenSource();
        cts.CancelAfter(timeout);
        try
        {
            Task.Run(action, cts.Token).Wait();
        }
        catch (TaskCanceledException e)
        {
            //here you know the task is cancelled due to timeout
        }
    }

最新更新