Blazor后台服务无法正常停止/取消的问题排查与优化

你的问题核心在于异步操作未绑定取消令牌，以及取消检查的时机存在盲区，导致服务内部的取消逻辑无法及时触发，最终只能在外部手动调用Stop()。

问题根源分析 #

1. 异步读取未响应取消信号：你调用await reader.ReadLineAsync()时未传入cancellationToken，导致触发取消后，读取操作不会立刻终止，而是继续等待直到读取完成，服务内部的取消检查逻辑根本没机会执行。
2. 取消逻辑重复且遗漏：虽然在部分位置写了cancellationToken.IsCancellationRequested检查，但异步操作未绑定令牌的情况下，这些检查无法及时响应取消请求。
3. 资源管理不严谨：手动管理StreamReader的Dispose容易遗漏，增加了资源泄漏风险。

优化步骤 #

1. 给所有异步方法绑定取消令牌 #

修改服务内的读取逻辑，将cancellationToken传递给所有支持取消的异步方法，确保取消信号能传递到整个读取流程：

// 替换原有的ReadLineAsync调用
string? line = await reader.ReadLineAsync(cancellationToken);

while (line != null) 
{
    if (line == "")
    {
        // 这里同样要传入取消令牌
        line = await reader.ReadLineAsync(cancellationToken);
        continue;
    }

    // ... 单词统计逻辑 ...

    // 防御性检查：确认取消请求已触发
    if (cancellationToken.IsCancellationRequested)
    {
        throw new OperationCanceledException(cancellationToken);
    }

    // ... 进度更新逻辑 ...

    // 读取下一行时绑定取消令牌
    line = await reader.ReadLineAsync(cancellationToken);
}

2. 注册取消回调自动执行Stop() #

在GetWordCounts方法开头添加取消令牌的注册回调，确保触发取消时自动调用Stop()，避免在多个位置重复编写相同逻辑：

public async Task<IOrderedEnumerable<KeyValuePair<string, int>>?> GetWordCounts(
    IEnumerable<IBrowserFile> files,
    CancellationToken cancellationToken)
{
    // 注册取消回调：一旦触发取消，自动执行Stop()
    using var cancellationRegistration = cancellationToken.Register(Stop);
    
    Running = true;
    Dictionary<string, int> wordCounts = new Dictionary<string, int>();
    // ... 后续原有逻辑 ...
}

3. 使用using自动管理StreamReader资源 #

替换手动Dispose的逻辑，用using包裹StreamReader，确保无论正常完成还是取消，资源都会被自动释放：

// 替换原有的StreamReader创建代码
using var reader = new StreamReader(file.OpenReadStream(maxFileSize, cancellationToken));

同时简化Stop()方法，移除手动释放reader的逻辑：

public void Stop()
{
    Running = false;
    // 移除reader?.Dispose()，using语句已自动处理资源释放
}

4. 移除UI层的冗余Stop()调用 #

现在服务内部会正确响应取消并执行Stop()，UI层的catch块可以移除Service.Stop()：

private async void InputFileChanged(InputFileChangeEventArgs e)
{
    if (Service.Running)
    {
        return;
    }

    IReadOnlyList<IBrowserFile> files = e.GetMultipleFiles();

    try
    {
        cancellationTokenSource = new CancellationTokenSource();
        wordCounts = await Service.GetWordCounts(files, cancellationTokenSource.Token);
        progressPercentage = 100;
    }
    catch (OperationCanceledException ex)
    {
        // 移除Service.Stop()，服务内部已自动处理
        wordCounts = null;
        progressPercentage = 0;
    }

    StateHasChanged();
}

额外细节优化 #

• 进度计算的字节数估算（字符数+换行符）仅适用于ANSI编码，若要兼容更多编码，可通过Stream.Position获取实际读取的字节数。
• 确保GetWordCounts方法在正常完成时，最终会将Running设置为false，避免状态不一致。

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