在 ef core 中传递取消令牌（cancellationtoken）非常简单，只需将 cancellationtoken 实例作为最后一个参数传入查询方法即可。例如调用 tolistasync() 或 firstordefaultasync() 时，直接传入一个已创建的 cancellationtokensource 的 token 属性，这样当请求被取消时，底层的数据库操作也会立即停止并抛出异常。
如何为单个异步查询方法添加取消令牌？
针对单个查询，直接在方法调用处追加 CancellationToken 参数即可生效。EF Core 支持的所有异步查询扩展方法都重载了接受令牌的版本，调用后若令牌被触发，会中断当前正在执行的 SQL 命令。
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;
public class Program
{
public static async Task Main()
{
using var cts = new CancellationTokenSource();
// 模拟在 100ms 后取消请求
_ = Task.Run(async () =>
{
await Task.Delay(100);
cts.Cancel();
});
try
{
using var db = new AppDbContext();
// 关键：将 Token 传递给 ToListAsync
var users = await db.Users.ToListAsync(cts.Token);
Console.WriteLine($"获取到 {users.Count} 条数据");
}
catch (OperationCanceledException)
{
Console.WriteLine("查询已被取消");
}
catch (Exception ex)
{
Console.WriteLine($"发生错误: {ex.Message}");
}
}
}
public class User
{
public int Id { get; set; }
public string Name { get; set; }
}
public class AppDbContext : DbContext
{
public DbSet<user> Users { get; set; }
protected override void OnConfiguring(DbContextOptionsBuilder options)
{
options.UseSqlServer("Server=(localdb)\mssqllocaldb;Database=TestDb;");
}
}</user>
运行上述代码，由于在 100 毫秒后调用了 Cancel，如果数据库查询耗时超过此时长，程序将捕获 OperationCanceledException 并输出“查询已被取消”。若查询在取消前完成，则正常返回结果。
如何在批量更新或删除操作中传递取消令牌？
除了读取数据，EF Core 的 ExecuteUpdateAsync 和 ExecuteDeleteAsync 等写操作方法同样支持取消令牌。这在执行可能影响大量数据的维护性任务时非常有用，可以防止长时间锁表。
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;
public class BatchProgram
{
public static async Task RunBatch()
{
using var cts = new CancellationTokenSource();
// 模拟长时间运行的任务被取消
_ = Task.Run(async () =>
{
await Task.Delay(50);
cts.Cancel();
});
try
{
using var db = new AppDbContext();
// 关键：将 Token 传递给 ExecuteUpdateAsync
var affected = await db.Users
.Where(u => u.Name == "Temp")
.ExecuteUpdateAsync(setters => setters.SetProperty(u => u.Name, "Cleaned"), cts.Token);
Console.WriteLine($"更新了 {affected} 行");
}
catch (OperationCanceledException)
{
Console.WriteLine("批量更新已被取消");
}
}
}
在此场景中，ExecuteUpdateAsync 接收两个参数，第二个参数即为 CancellationToken。当 cts.Cancel() 被调用时，EF Core 会尝试中止生成的 SQL 语句的执行。注意，某些数据库提供程序可能在命令发送后无法立即中断，但大多数现代驱动支持超时或中断机制。
如果在查询过程中手动检查 IsCancellationRequested 会发生什么？
如果在查询开始前或中间手动检查 IsCancellationRequested 属性，可以在发出数据库请求之前提前退出，从而节省网络往返和数据库资源。这是一种主动防御策略，适用于构建复杂的自定义查询逻辑。
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;
public class ManualCheckProgram
{
public static async Task CheckManual()
{
using var cts = new CancellationTokenSource();
cts.Cancel(); // 预先取消
try
{
using var db = new AppDbContext();
// 手动检查：如果已取消，不发起查询
if (cts.Token.IsCancellationRequested)
{
Console.WriteLine("请求已取消，跳过查询");
return;
}
var count = await db.Users.CountAsync(cts.Token);
Console.WriteLine($"总数: {count}");
}
catch (OperationCanceledException)
{
Console.WriteLine("查询过程中被取消");
}
}
}
当 IsCancellationRequested 为 true 时，代码直接返回，不会调用 CountAsync，因此不会产生任何数据库流量。这种模式通常用于在循环中执行多个查询，或者在构建大型 LINQ 表达式树之前进行快速失败判断。
