LINQのと非同期ラムダ

Question

次のコード...

using System; 
using System.Linq; 
using System.Threading.Tasks; 

namespace ConsoleAsync 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      MainAsync(args).Wait(); 
      Console.ReadLine(); 
     } 

     static async Task MainAsync(string[] args) 
     { 
      int[] test = new[] { 1, 2, 3, 4, 5 }; 

      if (test.Any(async i => await TestIt(i))) 
       Console.WriteLine("Contains numbers > 3"); 
      else 
       Console.WriteLine("Contains numbers <= 3"); 
     } 

     public static async Task<bool> TestIt(int i) 
     { 
      return await Task.FromResult(i > 3); 
     } 
    } 
} 

はあなたに次のエラーを与える： - あなたは非同期で動作するにはどうすればよいのライン

if (test.Any(async i => await Test.TestIt(i))) 

で

CS4010: Cannot convert async lambda expression to delegate type 'Func<int, bool>'. An async lambda expression may return void, Task or Task<T>, none of which are convertible to 'Func<int, bool>'.

Lambdasとlinq？

Answer 1

LINQですぐに使用することはできません。しかし、あなたがこの作品を作ることができ、ほとんどの拡張メソッド書き込むことができます。

public static class AsyncExtensions 
{ 
    public static async Task<bool> AnyAsync<T>(
     this IEnumerable<T> source, Func<T, Task<bool>> func) 
    { 
     foreach (var element in source) 
     { 
      if (await func(element)) 
       return true; 
     } 
     return false; 
    } 
} 

をそして、このようにそれを消費：

static async Task MainAsync(string[] args) 
{ 
    int[] test = new[] { 1, 2, 3, 4, 5 }; 

    if (await test.AnyAsync(async i => await TestIt(i)) 
     Console.WriteLine("Contains numbers > 3"); 
    else 
     Console.WriteLine("Contains numbers <= 3"); 
} 

それは私にはちょっと面倒を感じませんが、それはあなたの目標を達成します。

Answer 2

LINQメソッドの小さなサブセットで作業している場合は、@ YuvalItzchakovの答えに従うことをお勧めします。これは、基本クラスライブラリの一部として使用できるコンポーネントのみに依存するためです。

非同期シーケンスに対する豊富なクエリ機能が必要な場合は、代わりにRx.NETを使用できます。 RxはTask -returning代表者と協力それらのいくつかの非同期シーケンスを超えるLINQメソッドの広い配列、すなわちSelectMany提供：

IEnumerable<int> numbers = Enumerable.Range(0, 10); 

IEnumerable<int> evenNumbers = numbers 
    .ToObservable() 
    .SelectMany(async i => new { Value = i, IsMatch = await IsEven(i) }) 
    .Where(a => a.IsMatch) 
    .Select(a => a.Value) 
    .ToEnumerable(); 

async Task<bool> IsEven(int i) 
{ 
    await Task.Delay(100); 

    return i % 2 == 0; 
} 

Answer 3

まあ偉大な答えを、私はのYuval Itzchakovのアプローチで成長しているメソッドの数を見ることができました。それは醜いですが、あなたが使用することができます...

public static class AsyncExtensions 
{ 
    public static Func<T, bool> Convert<T>(Func<T, Task<bool>> func) 
    { 
     return t => func(t).Result; 
    } 
} 

そして、このようにそれを消費：醜さのほかに

static async Task MainAsync(string[] args) 
    { 
     int[] test = new[] { 1, 2, 3, 4, 5 }; 

     if (test.Any(i => AsyncExtensions.Convert((Func<int, Task<bool>>)(async x => await TestIt(x)))(i))) 
      Console.WriteLine("Contains numbers > 3"); 
     else 
      Console.WriteLine("Contains numbers < 3"); 
    } 

、当然の大きな問題は、そのブロック、基本的に同期コードを非同期コードを呼び出すことです。私はまだYuval Itzchakovのアプローチを使用しますが、私は非同期のためにLINQをもう一度実装せずにこれを行う方法があることを望みます。

Answer 4

How do you work with Async Lambdas and linq?

私はそれを回しても気にしませんか？どのようには彼らをしたいですか？

非同期ストリームの処理を開始するときはいつでも、セマンティクスに関する多くの疑問があります。 LINQのようにWhere節を叩くだけではありません。

この場合、同期ソースシーケンスに適用される「async where」フィルタがあります。非同期コードのアイデアの全体は、非同期操作には時間がかかります（その操作が進行中に呼び出しスレッドを解放したい場合）。フィルタが呼び出されたときにである「どこ非同期」

だから、最初の質問はについて回答します。ソースシーケンスは同期（配列）なので、すべての入力値をすぐに使用できます。 "async where"は、すべての要素の非同期フィルタを同時に開始するか、一度に1つずつ処理する必要がありますか？

これは実際の「非同期場所」ではなく「任意非同期」であった場合、次の問題は、得られる配列（結果が評価され、すなわち、）のを注文あろう。すべての非同期フィルターを同時に開始すると、開始された順序とは異なる順序で完了することができます。非同期フィルタがtrueを返すとすぐに結果の非同期シーケンスが最初の値を生成するか、または結果のシーケンスが元の値を同じ順序で保持するかどうかを指定します（バッファリングを意味します）。

異なるシナリオでは、これらの質問に対して異なる回答が必要です。 Rxはこれらの回答のどれかを表現することができますが、学習するのはむしろ困難です。 Async/awaitは読みやすいが表現力は低い。

これはです（Whereと一般的ではありません）。最初の質問があります。フィルタは同時に実行することも、1つずつ実行することもできますか？

一度に一つあれば、のYuvalのようなアプローチが働くだろう：

bool found = false; 
foreach (var i in test) 
{ 
    if (await TestIt(i)) 
    { 
    found = true; 
    break; 
    } 
} 
if (found) 
    Console.WriteLine("Contains numbers > 3"); 
else 
    Console.WriteLine("Contains numbers <= 3"); 

フィルタはこのような何かそして、同時に実行できる場合は、次の

var tasks = test.Select(i => TestIt(i)).ToList(); 
bool found = false; 
while (tasks.Count != 0) 
{ 
    var completed = await Task.WhenAny(tasks); 
    tasks.Remove(completed); 
    if (await completed) 
    { 
    found = true; 
    break; 
    } 
} 
if (found) 
    Console.WriteLine("Contains numbers > 3"); 
else 
    Console.WriteLine("Contains numbers <= 3");