主页 / 问题 / 1584452
Accepted
yava43
Asked:2024-06-19 16:56:36 +0000 UTC2024-06-19 16:56:36 +0000 UTC

异步 Dapper 请求中的取消令牌

  • 772

Daper 不会使用复杂查询的取消标记来重载 QueryAsync 方法。

现在是这样的：

var purchases = await connection.QueryAsync(queryWithFilters, types, mapper,
    param: new { Skip = skip, Take = take },
    splitOn: "Id,Id,Id,Id,Id,Id,Id");

这就是需要实现取消的地方。我在互联网上找不到它。对于较轻的查询，我使用 CommandDefinition。

该怎么办？

c#

1 个回答

  1. Best Answer

    如果你像这样拐杖：

    var purchasesTask = connection.QueryAsync(queryWithFilters, types, mapper,
    param: new { Skip = skip, Take = take },
    splitOn: "Id,Id,Id,Id,Id,Id,Id");
const int timeout = 60000; //ms
var delayTask = Task.Delay(timeout, token); // CancellationToken
var fastest = await Task.WhenAny(purchasesTask, delayTask);

if (fastest == delayTask)
{
    // таймаут или отмена
}
else
{
    var purchases = purchasesTask.Result; // можно await, но Task уже гарантированно завершён, и здесь можно и нужно .Result
    // ...
}

    这里请求没有被中断，而是被扔进了深渊。然而，停止等待的任务已经完成，如果这对你来说足够了，那么这就是一个很好的解决方案。

    但奇怪的是这样的请求却无法通过处理CommandDefinition。

    • 2

相关问题