Хотя LINQ на самом деле не имеет этого самого по себе, сама структура делает это ... Вы можете легко свернуть свой собственный исполнитель асинхронных запросов в 30 строк или около того ... На самом деле, я просто собрал это вместе для вас :)
РЕДАКТИРОВАТЬ: Написав это, я обнаружил, почему они не реализовали это. Он не может обрабатывать анонимные типы, поскольку они имеют локальную область видимости. Таким образом, у вас нет возможности определить функцию обратного вызова. Это довольно важная вещь, так как многие вещи linq to sql создают их в предложении select. Любое из приведенных ниже предложений постигнет та же участь, поэтому я все же думаю, что это самое простое в использовании!
РЕДАКТИРОВАТЬ: Единственное решение состоит в том, чтобы не использовать анонимные типы. Вы можете объявить обратный вызов как просто принимающий IEnumerable (без аргументов типа), и использовать отражение для доступа к полям (ICK !!). Другим способом было бы объявить обратный вызов как "динамический" ... о ... подождите ... Это еще не вышло. :) Это еще один достойный пример того, как можно использовать динамический. Некоторые могут назвать это оскорблением.
Добавьте это в свою библиотеку утилит:
public static class AsynchronousQueryExecutor
{
public static void Call<T>(IEnumerable<T> query, Action<IEnumerable<T>> callback, Action<Exception> errorCallback)
{
Func<IEnumerable<T>, IEnumerable<T>> func =
new Func<IEnumerable<T>, IEnumerable<T>>(InnerEnumerate<T>);
IEnumerable<T> result = null;
IAsyncResult ar = func.BeginInvoke(
query,
new AsyncCallback(delegate(IAsyncResult arr)
{
try
{
result = ((Func<IEnumerable<T>, IEnumerable<T>>)((AsyncResult)arr).AsyncDelegate).EndInvoke(arr);
}
catch (Exception ex)
{
if (errorCallback != null)
{
errorCallback(ex);
}
return;
}
//errors from inside here are the callbacks problem
//I think it would be confusing to report them
callback(result);
}),
null);
}
private static IEnumerable<T> InnerEnumerate<T>(IEnumerable<T> query)
{
foreach (var item in query) //the method hangs here while the query executes
{
yield return item;
}
}
}
И вы можете использовать это так:
class Program
{
public static void Main(string[] args)
{
//this could be your linq query
var qry = TestSlowLoadingEnumerable();
//We begin the call and give it our callback delegate
//and a delegate to an error handler
AsynchronousQueryExecutor.Call(qry, HandleResults, HandleError);
Console.WriteLine("Call began on seperate thread, execution continued");
Console.ReadLine();
}
public static void HandleResults(IEnumerable<int> results)
{
//the results are available in here
foreach (var item in results)
{
Console.WriteLine(item);
}
}
public static void HandleError(Exception ex)
{
Console.WriteLine("error");
}
//just a sample lazy loading enumerable
public static IEnumerable<int> TestSlowLoadingEnumerable()
{
Thread.Sleep(5000);
foreach (var i in new int[] { 1, 2, 3, 4, 5, 6 })
{
yield return i;
}
}
}
Собираюсь поставить это в моем блоге сейчас, довольно удобно.