public async Task StartAsync()
{
_cancellationTokenSource = new CancellationTokenSource();
CancellationToken token = _cancellationTokenSource.Token;
_heartbeatManager.StartHeartbeatService(token);
为什么要传TOKEN
在 C# 中,将CancellationToken
传递给StartHeartbeatService
方法是为了支持异步操作的取消。这是一种常见的模式,用于在需要时优雅地终止长时间运行的任务(如心跳服务)。
为什么需要传递 CancellationToken?
协作式取消机制
C# 中的异步操作不会被强制终止,而是通过协作式取消实现。CancellationToken
是一个令牌,允许你请求取消操作,而具体的操作逻辑需要检查这个令牌并决定如何响应。避免资源泄漏
如果心跳服务是一个周期性任务(如定时发送 Ping 包),不提供取消机制会导致任务持续运行,即使应用程序已经准备关闭。这可能导致资源泄漏或异常行为。与其他异步操作保持一致
遵循.NET 的最佳实践,长时间运行的异步方法应该接受CancellationToken
参数,以便与其他异步 API(如Task.WhenAny
、Task.Delay
等)协同工作。
示例:心跳服务如何使用 CancellationToken
假设StartHeartbeatService
的实现如下:csharp
public async Task StartHeartbeatService(CancellationToken cancellationToken)
{
while (!cancellationToken.IsCancellationRequested)
{
try
{
// 发送心跳包
await SendHeartbeatAsync();
// 等待指定间隔后再次发送
await Task.Delay(HeartbeatInterval, cancellationToken);
}
catch (OperationCanceledException)
{
// 任务被取消,正常退出
Console.WriteLine("心跳服务已取消");
}
catch (Exception ex)
{
// 处理其他异常
Logger.LogError(ex, "心跳服务异常");
}
}
}
调用方如何触发取消?
在你的代码中,_cancellationTokenSource
是一个类成员变量,因此可以在其他方法中触发取消:
// 启动服务
public async Task StartAsync()
{
_cancellationTokenSource = new CancellationTokenSource();
await _heartbeatManager.StartHeartbeatService(_cancellationTokenSource.Token);
}
// 停止服务
public void Stop()
{
_cancellationTokenSource?.Cancel();
_cancellationTokenSource?.Dispose();
_cancellationTokenSource = null;
}
最佳实践
传递令牌到所有子操作
如果StartHeartbeatService
内部调用其他支持取消的异步方法(如Task.Delay
、HttpClient.SendAsync
),应将令牌传递给它们,确保整个操作链都能响应取消请求。定期检查令牌状态
在循环或长时间运行的操作中,定期检查cancellationToken.IsCancellationRequested
,以便在没有等待操作时也能响应取消。异常处理
捕获OperationCanceledException
以优雅地处理取消请求,避免将其视为错误。
总结
传递CancellationToken
的目的是让心跳服务能够:
- 在应用程序关闭时安全停止。
- 在需要时(如检测到连接断开)主动终止。
- 避免资源泄漏和孤儿任务。
这是实现可取消异步操作的标准做法,是编写健壮、可维护代码的关键。