如何在等待超时的情况下取消任务而不抛出异常

9

使用取消令牌取消一个具有超时的任务(在超时结束之前),会抛出异常。例如:

mytask.start();
bool didTaskRunInTime = mytask.wait(5 mins, _cancelToken);

这意味着我不能像下面这样继续进行。
//was the task cancelled
if (_cancelToken.IsCancelRequested)
{
    // log cancel from user to file etc
}

if (didTaskRunInTime )
{
    int taskResult = myTask.Result;
    // log result to file
}
else if (!_cancelToken.IsCancelRequested)
{
    // Tell user task timed out , log a message etc
}

我必须在捕获块中完成所有这些操作,我的代码看起来很混乱。有什么正确的方法可以做到这一点?

2个回答

18

您可以用一个只有任务的数组调用 Task.WaitAny。然后,无论该方法返回什么状态,您都可以对任务的状态进行操作。以下是示例代码:

using System;
using System.Threading;
using System.Threading.Tasks;

class Test
{
    static void Main()
    {
        Task sleeper = Task.Factory.StartNew(() => Thread.Sleep(100000));

        int index = Task.WaitAny(new[] { sleeper },
                                 TimeSpan.FromSeconds(0.5));
        Console.WriteLine(index); // Prints -1, timeout

        var cts = new CancellationTokenSource();

        // Just a simple wait of getting a cancellable task
        Task cancellable = sleeper.ContinueWith(ignored => {}, cts.Token);

        // It doesn't matter that we cancel before the wait
        cts.Cancel();

        index = Task.WaitAny(new[] { cancellable },
                             TimeSpan.FromSeconds(0.5));
        Console.WriteLine(index); // 0 - task 0  has completed (ish :)
        Console.WriteLine(cancellable.Status); // Cancelled
    }
}

请注意,如果任务出现故障,您应该“观察”异常以避免在完成时出现问题 :)

我认为它会抛出异常,WaitAny将聚合所有异常,您甚至应该在waitAny之后调用wait(并可能取消其他操作),以便捕获它们的异常。 - eFloh
谢谢约翰。但是waitany不会设置超时。我有一个长时间运行的导出任务需要处理超时。 - Gullu
1
@eFloh:WaitAll会聚合异常,而WaitAny则不会。请参考示例代码。 - Jon Skeet
@Gullu:是的,它可以(或者至少可以)-请看我的示例代码 :) - Jon Skeet
谢谢Jon。解决方案肯定没问题。但是现在处理异常看起来更易读和易于维护 :-) 就像Vlad下面展示的那样。 - Gullu
显示剩余2条评论

3
尝试使用OperationCanceledException。
try
{           
    mytask.start();
    bool didTaskRunInTime = mytask.wait(5 mins, _cancelToken);

    if (didTaskRunInTime )
    {
        int taskResult = myTask.Result;
        //log result to file
    }
    else
    {
        // Tell user task timed out , log a message etc
    }
}
catch (OperationCanceledException ex)
{
    // log cancel from user to file et
}

那正是我试图避免的,但我可能别无选择。我的理解是,如果有人设置了取消令牌并打算取消,为什么这个东西还要设计成抛出异常呢?谢谢 Vlad。 - Gullu
这里没有使用异常的要求 - 可以参考我的答案,其中根本没有使用try/catch。 - Jon Skeet

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接