비동기식 술어를 사용하여 목록을 필터링하는 방법

Question

문자열 목록 (예 : 문자열을 예로 든 것)이 있다고 가정합니다.

IEnumerable<string> fullList = ...; 

과 같은 비동기 술어입니다.

static Task<bool> IncludeString(string s) { ... } 

다음과 같은 제약, 술어하여 목록을 필터링하는 가장 간단한 방법은 무엇 :

1. 조건부 실행하지 않아야 순차적으로 (목록이 긴 및 비동기 술어가 느린 가정은)
나는 해결책을 찾을 않았다

주문 보존한다 필터링 된 목록을 결과

,하지만 PRED의 결과가 임시 목록을 작성 포함 각 항목에 대해 퀴즈를 작성한 다음이를 사용하여 필터링을 수행하십시오. 그것은 단지 충분히 우아하게 느끼지 않습니다. 여기에 있습니다 :

var includedIndices = await Task.WhenAll(fullList.Select(IncludeString)); 
var filteredList = fullList.Where((_, i) => includedIndices[i]); 

간단한 프레임 워크 호출에서 가능해야하지만 뭔가를 찾을 수 없었습니다. 당신은 당신이 필요로하는 Linq 기능 당신 자신의 구현을 만들 수

Answer 1

특별히 우아하지는 않지만 선택 영역의 Task.ContinueWith 호출에서 익명 형식을 만들고 해당 배열에서 WhenAll 호출을 기다리고 해당 작업 결과에 포함 된 값을 사용할 수 있습니다. 열거시에도 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; })); 

주 - 그것을 :

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(); 
} 

사용 예제 (시연했다-up 기능) Task.WhenAll은 LINQy lazy 열거 형을 반환하지 않기 때문에 게으르지 않을 것입니다.

Answer 2

, 즉

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>>입니다. 목록의 각 항목에 대해