如何在一段时间后停止异步任务

Question

我正试图在一段时间后停止 C# 中的任务。

对于我的代码：Task.Delay().Wait() 应该只代表 Task 所做的一些工作。

我的代码：

public static void Main()
{
    Console.WriteLine("starting app");
    try
    {
        Console.WriteLine("before");
        DoStuff(1000);
        Console.WriteLine("after");
    }
    catch
    {
        Console.WriteLine("TIMEOUT");
    }
    Console.WriteLine("Main finished wait 5 sec now");
    Task.Delay(10000).Wait();
    Console.WriteLine("Closing app now");
}

public static async Task DoStuff(int time)
{
    Task real = Task.Run(()=>
    {
        Task.Delay(2000).Wait();
        Console.WriteLine("Task Running");
        Task.Delay(2000).Wait();
        Console.WriteLine("still running");
        Task.Delay(2000).Wait();
        Console.WriteLine("Not dead yet");
        Task.Delay(1000).Wait();
        Console.WriteLine("Task done");
        Task.Delay(5000);
    });

    bool success = real.Wait(time);
    if ( success )
    {
        Console.WriteLine("Task finished in time");
        await real;
    }
    else
    {
        Console.WriteLine("Task did not finish");
        real.Dispose();
        throw new TimeoutException("The task took too long");
    }
}

我已经尝试使用取消令牌，但我没有循环来检查每次迭代的令牌。所以我尝试用Task.Wait(time) 来做这件事，我得到了正确的信息，但是在使用Task.Dispose() 方法后任务并没有停止。我得到以下输出：

所以我得到了当前的输出，但任务继续在后面运行..关于如何解决这个问题的任何想法？

Answer 1

首先：永远不要Wait() 处理任务（除非你知道他们已经完成了）；使用await。至于超时：CancellationTokenSource可以延时后超时，如下。

请注意，取消令牌不会中断代码-您（或其他代码，如Task.Delay）需要检查取消（对于例如，ThrowIfCancellationRequested())，或者您需要使用 Register(...) 添加一个回调，该回调将在取消时调用。

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

static class P
{

    public static async Task Main()
    {
        Console.WriteLine("starting app");
        try
        {

            Console.WriteLine("before");
            await DoStuffAsync(1000);
            Console.WriteLine("after");
        }
        catch
        {
            Console.WriteLine("TIMEOUT");
        }
        Console.WriteLine("Main finished wait 5 sec now");
        await Task.Delay(5000);
        Console.WriteLine("Closing app now");
    }
    public static async Task DoStuffAsync(int time)
    {
        using var cts = new CancellationTokenSource(time); // assuming here that "time" is milliseconds
        Task real = Task.Run(async () =>
        {
            await Task.Delay(2000, cts.Token);
            Console.WriteLine("Task Running");
            await Task.Delay(2000, cts.Token);
            Console.WriteLine("still running");
            await Task.Delay(2000, cts.Token);
            Console.WriteLine("Not dead yet");
            await Task.Delay(2000, cts.Token);
            Console.WriteLine("Task done");
            await Task.Delay(2000, cts.Token);
        });

        bool success;
        try
        {
            await real;
            success = true;
        }
        catch (OperationCanceledException)
        {
            success = false;
        }

        if (success)
        {
            Console.WriteLine("Task finished in time");
        }
        else
        {
            Console.WriteLine("Task tool too long");
        }
    }
}

请注意，您也可以将取消令牌传递给Task.Run，但这只是在执行回调之前检查 - 而且没有通常会造成很大的延迟，所以...通常不值得。

附加说明：如果您想确定究竟是什么被取消（即OperationCanceledException 来自cts）：

catch (OperationCanceledException cancel) when (cancel.CancellationToken == cts.Token)