当发生异常时，如何取消iAsyncencentoser？

Question

我正在使用iasyncenumerable来获取大量数据 - 像这样：

static async IAsyncEnumerable<int> GetSequence([EnumeratorCancellation] CancellationToken ct = default)
{
    for (int i = 1; i <= 10; i++)
    {
        var data = await DoSomethingAsync()    // get data from web request
        yield return data;
    }
}

现在是我的问题：如果dosomethingsasync thr thr thr tragriation（也许是网络问题），我想取消剩余的请求，有可能吗？

我正在尝试以下代码来处理，但仍然需要帮助：

CancellationTokenSource source = new CancellationTokenSource();
CancellationToken token = source.Token;

try
{
    IAsyncEnumerable<int> dataCol = GetSequence(token);

    await foreach (var d in dataCol)
    {
        // do ...
    }
}
catch (Exception)
{
   source.Cancel(true);
   throw;
}

感谢某人有最佳实践

Answer 1

来自原始

await foreach (var d in dataCol)
{
    // do ...
}

等同于;

{
    E e = dataCol.GetAsyncEnumerator();
    try {
        while (await e.MoveNextAsync()) {
            var d = e.Current;
            // do ...
        }
    }
    finally {
        ... // Dispose e
    }
}

调用movenextAsync导致您的get sequence方法执行到下一个收益率返回，或者直到抛出未手动的异常为止。执行该方法不会恢复，直到下一个呼叫moveNextAsync。 get sequence和等待着foreach不同行运行，他们轮流执行更多的代码在同步的任务中。

如果Dosomethingsasync抛出异常

，则等待e.movenextasync（）将重新添加异常。然后将处置枚举者。然后，异常将堆栈流到下一个异常处理程序。

您无需弄乱取消令牌即可防止获取序列恢复执行。实际上，从中分解出循环也将中止执行，好像收益率返回从未恢复过。在get sequence方法中，导致任何终于{}块执行，如果有的话。