异步LINQ-不是懒惰吗？多线程？

Question

我有以下代码：

var things = await GetDataFromApi(cancellationToken);

var builder = new StringBuilder(JsonSerializer.Serialize(things));

await things
    .GroupBy(x => x.Category)
    .ToAsyncEnumerable()
    .SelectManyAwaitWithCancellation(async (category, ct) =>
    {
        var thingsWithColors = await _colorsApiClient.GetColorsFor(category.Select(thing => thing.Name).ToList(), ct);
        
        return category
            .Select(thing => ChooseBestColor(thingsWithColors))
            .ToAsyncEnumerable();
    })
    .ForEachAsync(thingAndColor =>
    {
        Console.WriteLine(Thread.CurrentThread.ManagedThreadId); // prints different IDs
        builder.Replace(thingAndColor.Thing, $"{thingAndColor.Color} {thingAndColor.Thing}");
    }, cancellationToken);

它使用＜code＞System.Linq。异步，我发现很难理解。在“经典”/“同步LINQ”中，只有在调用＜code＞ToList（）

我担心的另一个问题是多线程。我听过很多次异步！=多线程。那么，< code >控制台怎么可能。WriteLine(线程。CurrentThread . ManagedThreadId)；打印各种id？有些id被打印了多次，但总的来说，输出中大约有5个线程id。我的代码都没有显式创建任何线程。这都是异步等待。< code>StringBuilder不支持多线程，我想知道上面的实现是否有效。

请忽略我的代码的算法，这并不重要，只是一个例子。重要的是System.Async.Linq的使用。

Answer 1

<代码>系统。Async.Linq，以及整个dotnet/reactive存储库，目前是一个半废弃的项目。GitHub上的问题堆积如山，几乎一年都没有人正式回答。除了每个方法的源代码中的XML文档之外，没有发布任何文档。如果不研究源代码，你就不能真正使用这个库，这通常很容易做到，因为代码很短，可读性强，而且老实说不会做太多。该库提供的功能与< code >系统中的功能相似。Linq，主要区别在于输入是< code>IAsyncEnumerable

除了像< code>Merge(以及它的一个重载)这样的少数运算符之外，< code >系统。Async.Linq没有引入并发性。一次调用一个异步操作，然后在调用下一个操作之前等待它们。< code > selectmanyawaitwithcassignment 运算符不在例外之列。为每个元素顺序调用< code >选择器,并生成< code>IAsyncEnumerable

< code > foreach sync 运算符只是执行标准的< code>await foreach循环的替代品，在C#语言不支持< code>await foreach时(在C# 8之前)就包含在库中了。我建议不要使用这个操作符，因为它与新的< code >类似。foreach sync API可能会造成混乱。以下是写在< code > foreach sync 运算符源代码中的内容:

// REVIEW: Once we have C# 8.0 language support, we may want to do away with these
//         methods. An open question is how to provide support for cancellation,
//         which could be offered through WithCancellation on the source. If we still
//         want to keep these methods, they may be a candidate for
//         System.Interactive.Async if we consider them to be non-standard
//         (i.e. IEnumerable<T> doesn't have a ForEach extension method either).

Answer 2

ForEachAsync将具有与ToList/ToArray类似的效果，因为它强制评估整个列表。

默认情况下，等待之后的任何内容都在同一执行上下文中继续，这意味着如果代码在 UI 线程上运行，它将继续在 UI 线程上运行。如果它在后台线程上运行，它将继续在后台线程上运行，但不一定是同一个线程。

但是，任何代码都不应并行运行。这并不一定意味着它是线程安全的，可能需要一些内存障碍来确保数据被正确刷新，但我认为这些障碍是由框架代码本身发出的。