Task.Delay() 未按预期运行

Question

Task.Delay() 没有按预期运行，或者我不明白它应该做什么。我正在尝试了解 C# 中的 Tasks 以及如何在我的实现中替换 Threads。

我想做的是这样的：

• 虽然是真的
  • 打印一行
  • 等一下，
  • 如果条件满足则退出循环，否则继续循环

我已经用 Threads 很好地实现了，但所有酷孩子都说我应该使用 Task，不要碰 Thread。

所以对于我有这个的代码（忽略[Test] - 这只是一种方便的尝试方式）

    [Test]
    public void ChattyTask()
    {
        var chattyTask = new Task(ChattyWriter);
        chattyTask.Start();
        chattyTask.Wait();
    }

    public void ChattyWriter()
    {
        int count = 0;
        while (true)
        {
            var message = String.Format("Chatty Writer number {0}", count);
            Trace.WriteLine(message);
            count++;
            Task.Delay(1000);

            if (count >= 20)
            {
                break;
            }
        }
    }

当我运行它时，测试会在几毫秒内完成，而不是像我预期的那样在 20 秒内完成。如果我将Task.Delay() 替换为Thread.Sleep()，一切都会按预期进行，并且我会每秒打印一次。我尝试将async 和await 添加到ChattyWriter() 中，但它不仅没有增加1 秒的延迟，而且只打印了一行而不是20 行。

我做错了什么？

这可能有助于描述我在做什么：我的项目使用外部 API (RESTful)，在我请求一些任务发生后，我需要轮询 API 以检查任务是否已完成。外部任务可以长时间运行：1-15 分钟。所以我需要在检查完成之间有一些延迟。并且可能有许多不同的并发进程与多个外部任务一起执行。我明白，如果我在轮询时使用Thread.Sleep()，同一Thread 上的其他进程将无缘无故地被阻塞。

Answer 1

Task.Delay 返回一个您必须等待的 Task 对象。否则下面的代码将立即执行。因此，您必须将您的方法声明为async。然后就可以等待Task.Delay

public async Task ChattyWriter()
{
    int count = 0;
    while (true)
    {
        var message = String.Format("Chatty Writer number {0}", count);
        Trace.WriteLine(message);
        count++;
        await Task.Delay(1000);
           ...
    }
}

你必须以某种方式中断你的调用线程。单元测试将终止，后台线程也将终止。但是如果你从 UI 调用这个方法，UI 不会被阻塞。

通过在异步方法上调用Wait，您最终会陷入死锁。请参阅here 了解更多信息。

Answer 2

Task.Delay(1000); 创建一个异步任务，该任务将在一秒钟后完成，但当前方法的执行将继续并行。

为了等待任务先完成，你可以替换

Task.Delay(1000);

与

Task.Delay(1000).Wait();

Answer 3

Task.Delay() 实际上是创建一个任务，所以你只需要等待它。

试试这个

        public static void ChattyWriter()
    {
        int count = 0;
        while (true)
        {
            var message = String.Format("Chatty Writer number {0}", count);
            Console.WriteLine(message);
            count++;
            var t = Task.Delay(1000);
            t.Wait();

            if (count >= 20)
            {
                break;
            }
        }
    }