基于.NET TPL的C#定时轮询后台任务实现方案合理性咨询

原问题与代码 #

本人刚接触C#的Tasks及相关关键字，目标是实现一个每隔n秒轮询服务器的后台任务。现基于.NET TPL库编写了如下代码结构，请问该实现方式是否恰当？

private CancellationTokenSource _cts;
private CancellationToken _ct;

public override async Task StartSomeServiceAsync()
{
    _cts = new CancellationTokenSource();
    _ct = _cts.Token;

    await Task.Run(() => this.Work(_ct));
    
    //TODO Do some reporting, system management/cleanup etc... 
      after the task has been cancelled
}

protected override void Work(CancellationToken ct)
{        
    while (true)
    {
        if (ct.IsCancellationRequested)
            break;

        Thread.Sleep(5000);
        //Make network calls, collect data
        //Notify data subscribers of new data received from network
    }
}

public override void StopSomeService()
{
    _cts.Cancel();
}

该代码所属对象可通过调用StartSomeServiceAsync()启动后台任务，当满足外部条件时，可通过StopSomeService()调用取消该后台任务。恳请各位提供建议，感谢您的时间。

现有实现的问题 #

• 线程资源浪费：Thread.Sleep(5000)会直接阻塞线程池线程，在等待期间线程无法处理其他工作，不符合异步编程的高效性要求。
• 取消响应延迟：如果在Thread.Sleep过程中触发取消，任务要等5秒后才会检测到取消请求，无法及时响应。
• 异步方法未发挥异步价值：StartSomeServiceAsync用Task.Run包装同步方法，只是把同步工作转移到线程池，没有真正实现非阻塞异步。
• 缺少异常处理：轮询中的网络调用可能抛出异常，当前代码未做处理，会导致任务意外终止且无任何错误提示。
• 资源泄漏风险：CancellationTokenSource实现了IDisposable接口，当前代码未在任务结束后释放该资源。

优化后的实现方案 #

推荐基于异步API重构，充分利用.NET异步特性，同时优化取消逻辑与稳定性：

private CancellationTokenSource _cts;

public override async Task StartSomeServiceAsync()
{
    // 避免重复启动轮询任务
    if (_cts != null && !_cts.IsCancellationRequested)
        return;

    using (_cts = new CancellationTokenSource())
    {
        var ct = _cts.Token;
        try
        {
            while (!ct.IsCancellationRequested)
            {
                // 用异步等待替代Thread.Sleep，支持即时响应取消
                await Task.Delay(5000, ct);
                
                // 核心轮询操作使用异步API，避免阻塞线程
                await PollServerAsync(ct);
                
                // 通知数据订阅者
                NotifySubscribers();
            }
        }
        catch (OperationCanceledException)
        {
            // 任务被正常取消，可在此记录日志
        }
        catch (Exception ex)
        {
            // 处理轮询中的异常，比如记录错误、尝试重试
            // 可根据异常类型决定是否继续轮询
        }
        finally
        {
            // 执行清理、报告等收尾工作
            DoCleanupAndReporting();
        }
    }
}

protected virtual async Task PollServerAsync(CancellationToken ct)
{
    // 替换为实际的异步网络调用，例如HttpClient.GetAsync(..., ct)
    await Task.Delay(100, ct); // 示例异步操作
}

private void NotifySubscribers()
{
    // 实现通知订阅者的逻辑
}

private void DoCleanupAndReporting()
{
    // 资源清理、生成运行报告等逻辑
}

public override void StopSomeService()
{
    _cts?.Cancel();
    _cts?.Dispose();
}

关键优化点说明 #

• 替换Thread.Sleep为Task.Delay：Task.Delay是异步等待，不会阻塞线程，且支持传入CancellationToken，能在取消请求到达时立即抛出OperationCanceledException，实现即时取消。
• 异步化核心操作：网络调用等耗时操作优先使用异步API（如HttpClient的异步方法），最大化线程池资源利用率。
• 正确管理CancellationTokenSource：用using语句自动释放资源，避免泄漏；在StopSomeService中处理空引用，防止空指针异常。
• 完善异常处理：区分正常取消与异常错误，保证任务在遇到非致命异常时能继续运行，提升稳定性。
• 防止重复启动：启动前检查任务状态，避免多次调用StartSomeServiceAsync创建多个并行轮询任务。

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