异步方法调用阻塞主线程，SendMessage无法及时执行问题咨询

你编写了如下异步方法，原本预期调用BeginCheckingAsync后不会阻塞主线程，SendMessage()能立刻执行，但实际SendMessage()必须等checkTask完成后才会运行，想排查问题所在：

public async Task SpecifyAsync()
{
    CancellationTokenSource source = new();
    Task<long> checkTask = BeginCheckingAsync(source.Token);
    SendMessage();
    await checkTask;
}

更新补充：BeginCheckingAsync的代码如下：

private async Task<long> BeginCheckingAsync(CancellationToken cancellationToken)
{
    while (true)
    {
        var messages = _apiClient.GetNewMessages();

        foreach (var message in messages)
            if (ValidateMessage(message))
                return await Task.FromResult(Parse(message));

        cancellationToken.ThrowIfCancellationRequested();
    }
}

问题根源 #

核心问题是BeginCheckingAsync看起来是async方法，但全程都是同步阻塞逻辑，没有真正的异步操作：

• _apiClient.GetNewMessages()是同步调用，没有使用异步版本（比如GetNewMessagesAsync）
• 循环内没有任何await异步等待操作，导致方法会一直占用当前线程循环执行，直到找到符合条件的消息才返回
• return await Task.FromResult(Parse(message))完全多余，直接return Parse(message)即可，这行代码并没有让方法变成异步

所以当你调用BeginCheckingAsync(source.Token)时，这个方法会同步阻塞当前线程，直到循环退出才返回一个已完成的Task，自然SendMessage()要等它跑完才能执行。

修复方案 #

要实现真正的异步并行，需要修改BeginCheckingAsync，加入真正的异步操作：

1. 将同步的GetNewMessages()替换为对应的异步方法，并使用await等待
2. 循环等待时加入异步延迟，释放当前线程，避免空转
3. 移除无意义的await Task.FromResult

修改后的示例代码：

private async Task<long> BeginCheckingAsync(CancellationToken cancellationToken)
{
    while (true)
    {
        // 使用异步IO调用并等待结果
        var messages = await _apiClient.GetNewMessagesAsync(cancellationToken);

        foreach (var message in messages)
            if (ValidateMessage(message))
                return Parse(message);

        // 异步延迟，释放当前线程给其他任务使用
        await Task.Delay(100, cancellationToken);
        cancellationToken.ThrowIfCancellationRequested();
    }
}

修改后，BeginCheckingAsync遇到await时会释放当前线程，SendMessage()就能立刻执行，真正实现你预期的并行逻辑。

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