Как записать Асинхронный запрос LINQ?

В то время как LINQ действительно не имеет этого по сути, сама платформа делает... Вы можете легко самокрутка асинхронный исполнитель запроса приблизительно в 30 строках... На самом деле я просто бросил это вместе для Вас:)

РЕДАКТИРОВАНИЕ: Посредством записи этого я обнаружил, почему они не реализовали ее. Это не может обработать анонимные типы, так как они ограничены по объему локальные. Таким образом у Вас нет способа определить Вашу функцию обратного вызова. Это - довольно главная вещь, так как много linq к материалу sql создает их в избранном пункте. Любой из ниже предложений переносит ту же судьбу, таким образом, я все еще думаю, что этого является самым легким использовать!

РЕДАКТИРОВАНИЕ: единственное решение не состоит в том, чтобы использовать анонимные типы. Можно объявить обратный вызов как просто берущий IEnumerable (никакой тип args) и использовать отражение для доступа к полям (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;
        }
    }

}

Попытка пойти поднятый это на моем блоге теперь, довольно удобный.