尝试使用 async/await 时出现问题 [重复]

Question

我正在关注 thread 以使我的一些命令异步，而其他命令同步，但我遇到了一些问题。

这是我目前所拥有的。

一个接口：

public interface ICommand
{
    public Task ExecuteAsync();
}

我在一个应该是同步的等待命令中实现的。

public class WaitCommand : ICommand
{
    public Task ExecuteAsync()
    {
        Console.WriteLine("Sleeping...");
        Thread.Sleep(5000);
        Console.WriteLine("Waking up...");
        return Task.CompletedTask;
    }
}

还有另一个可以工作的命令，应该是异步的。

public class ConcreteCommand : ICommand
{
    public async Task ExecuteAsync()
    {
        await Task.Run(() =>
        {
            Console.WriteLine("Starting...");
            Thread.Sleep(1000);
            Console.WriteLine("Ending...");
        });
    }
}

然后我有某种方法可以读取字符串并将其转换为命令：

public async Task ExecuteAsync(string commandName)
    {
        ... get command

        await command.ExecuteAsync();
    }

最后我有一个循环

List<string> commands = new List<string>
{
    "concreteCommand",
    "wait",
    "concreteCommand"
};

foreach (String command in commands)
{
    await commandDispatcher.ExecuteAsync(command);
}

这是打印出来的。

Starting...
Ending...
Sleeping...
Waking up...
Starting...
Ending...

这意味着它不是异步运行的。我的实现有什么问题？

Answer 1

虽然Thread.Sleep(1000) 中没有任何异步，但所描述的问题行为的原因在于foreach 语句中的await：

foreach (String command in commands)
{
    await commandDispatcher.ExecuteAsync(command);
}

您基本上开始并等待每个命令结束，然后再继续下一步。改成：

await Task.WhenAll(commands.Select(command => commandDispatcher.ExecuteAsync(command)));

您将在 cmets 中获得接近预期的输出（尽管前两个语句的顺序可能不同）。

注意WaitCommand 在这种情况下会阻止下一个命令启动。如果这是我的目标，那么从性能的角度来看，最好以某种方式重构代码，这样您就不会仅仅为了等待而消耗线程和 CPU。例如这样的（示例代码，可能需要一些修复才能使其编译）：

List<string> commands = new List<string>
{
    "concreteCommand",
    "wait",
    "concreteCommand"
};

await commandDispatcher.ExecuteAsync(commands);

// Dispatcher 
public async Task ExecuteAsync(IEnumerable<string> commands)
{
   foreach (String commandName in commands)
   {
       //... get command
       if(command is WaitCommand)
       {
          await Task.Delay(5000); // or read from `WaitCommand` props
          // or use Task.Delay in WaitCommand and await command here
       }
       else
       {
          _ = command.ExecuteAsync(); // fire and forget which is usually not recommended
          // or add to some collection and await Task.WhenAll(...) after the loop
       }
   }
}

Answer 2

public class ConcreteCommand : ICommand
{
    public async Task ExecuteAsync(List<string> arguments)
    {
        // this await causes the caller of ExecuteAsync
        // to wait for the result of Task.Run
        await Task.Run(() =>
        {
            Console.WriteLine("Starting...");
            Thread.Sleep(1000);
            Console.WriteLine("Ending...");
        });
    }
}

顺便说一句，Thread.Sleep 是超级老派和邪恶的。它占用了线程，线程是昂贵的资源。这会使线程池混淆它有多少可用线程，并迫使它创建新线程。请改用await Task.Delay。