如何使用异步谓词筛选列表

它并不特别优雅,但可以在 Task.ContinueWith 从select中的谓词调用,等待 WhenAll 调用该数组,并使用这些任务结果中包含的值。

public async Task<T[]> FilterAsync<T>(IEnumerable<T> sourceEnumerable, Func<T, Task<bool>> predicateAsync)
{
    return (await Task.WhenAll(
        sourceEnumerable.Select(
            v => predicateAsync(v)
            .ContinueWith(task => new { Predicate = task.Result, Value = v })))
        ).Where(a => a.Predicate).Select(a => a.Value).ToArray();
}

// Returns { "ab", "abcd" } after 1000ms
string[] evenLengthStrings = await FilterAsync<string>(new string[] { "a", "ab", "abc", "abcd" }, (async s => { await Task.Delay(1000); return s.Length % 2 == 0; }));

注意,即使没有 ToArray 调用时,返回的枚举将 不 Task.WhenAll 不返回LINQy lazy枚举。

您可以创建自己的 Linq 您需要的功能,即。

public static async Task<IEnumerable<TIn>> FilterAsync<TIn>(this IEnumerable<TIn> source, Func<TIn, Task<bool>> action)
{
    if (source == null) throw new ArgumentNullException(nameof(source));
    if (action == null) throw new ArgumentNullException(nameof(action));

    var result = new List<TIn>();
    foreach (var item in source)
    {
        if (await action(item))
        {
            result.Add(item);
        }
    }

    return result;
}

那么你可以这样使用它

IEnumerable<string> example = new List<string> { "a", "", null, "   ", "e" };
var validStrings = await example.FilterAsync(IncludeString);
// returns { "a", "e" }

考虑到 IncludeString

public static Task<bool> IncludeString(string s) {
    return Task.FromResult(!string.IsNullOrWhiteSpace(s));
}

所以它基本上运行一个 async Func<int, Task<bool>> 对于列表中的每个项目