C#异步方法未立即执行，并行逻辑问题排查咨询

你希望并行执行数据库加载与FTP下载操作，但控制台未输出“Start getting messages”，程序未按预期并行运行。

调用方代码 #

var snapshotMessages = snapshotRepository.GetMessages();
_ = Console.Error.WriteLineAsync("Loading XML timetables...");
// some lengthy operation which loads a large dataset from a SQL database
await foreach (var item in snapshotMessages) {
    // process the item
}

被调用方代码 #

public async IAsyncEnumerable<Pport> GetMessages() {
    Console.Error.WriteLine("Start getting messages");
    var timestamp = DateTime.MinValue;
    // some code which start downloading a large file from FTP
}

官方文档描述 #

异步方法会同步运行，直到遇到第一个await表达式，此时方法会挂起，直到被等待的任务完成。与此同时，控制权返回给方法的调用方，如下一节示例所示。

核心原因：异步枚举的延迟执行特性 #

你误解了官方文档的适用场景：文档描述的是普通异步方法的行为，但async IAsyncEnumerable<T>属于异步枚举，它有一个关键特性——延迟执行：

• 普通异步方法在调用时就会立即执行代码，直到遇到第一个await才挂起并返回控制权。
• 但async IAsyncEnumerable<T>方法的代码，要等到你通过await foreach（或手动调用GetAsyncEnumerator+MoveNextAsync）开始枚举时，才会真正执行。

所以你的代码中，snapshotRepository.GetMessages()调用后，方法体里的Console.Error.WriteLine("Start getting messages")根本没执行，而是等到后面的数据库加载操作完成后，进入await foreach时才会触发，自然无法实现并行。

解决方法：提前触发异步枚举执行 #

要让FTP下载和数据库加载并行，你需要提前启动异步枚举的执行，让GetMessages里的代码在数据库加载时就开始运行。可以手动获取异步枚举器并提前调用MoveNextAsync：

// 提前获取异步枚举器，准备启动FTP下载
var messagesEnumerator = snapshotRepository.GetMessages().GetAsyncEnumerator();
// 启动第一个MoveNextAsync，触发GetMessages内的代码执行
var firstMoveTask = messagesEnumerator.MoveNextAsync().AsTask();

_ = Console.Error.WriteLineAsync("Loading XML timetables...");
// 执行数据库加载的耗时操作
// some lengthy operation which loads a large dataset from a SQL database

// 处理枚举结果
try {
    if (await firstMoveTask) {
        do {
            var item = messagesEnumerator.Current;
            // process the item
        } while (await messagesEnumerator.MoveNextAsync());
    }
} finally {
    // 务必释放枚举器资源
    await messagesEnumerator.DisposeAsync();
}

或者，如果你的FTP下载逻辑可以拆分为独立的异步任务（而非依赖异步枚举的逐次返回），也可以用Task.WhenAll来并行执行两个耗时操作，再处理结果。

内容的提问来源于stack exchange，提问作者Michael Tsang