1

Например, есть асинхронная функция, в которой имеются несколько Task'ов, и надо возвращать результат когда выполняться все Task'и, либо первый из них. Можно ли это сделать средствами async/await? Предполагаю, что нет, поэтому развиваю тему введением функции MagicFunction:

static async Task<string> DoIt()
{
    Random r = new Random();
    Task<string> t1 = Task.Delay(r.Next(3000)).ContinueWith(t => "one");
    Task<string> t2 = Task.Delay(r.Next(3000)).ContinueWith(t => "two");

    return await MagicFunction(t1, t2);
}

Если это так, то есть ли в .Net Framework такая функция, которая бы принимала несколько объектов типа Task и возвращала один Task, который завершается когда завершаются все/первый Task'и, которые мы передали как аргументы функции? Ну или как правильно написать такую функцию?

Вот набросал пример того, что хочу, но не уверен, что это самый оптимальный вариант

static Task<string> MagicFunction(Task<string> t1, Task<string> t2)
{
    TaskCompletionSource<string> res = new TaskCompletionSource<string>();
    Task.Factory.ContinueWhenAny(new Task<string>[] { t1, t2 }, t => res.SetResult(t.Result));

    return res.Task;
}
7
  • 4
    Task.WhenAll - Ждет все. Task.WhenAny - Ждет любой
    – Grundy
    Commented 16 янв. 2017 в 11:10
  • @Grundy, это очень нехороший вариант, так как в этом случает поток ждет и не выполняет никакой полезной работы
    – Qutrix
    Commented 16 янв. 2017 в 11:11
  • 2
    С чего ты взял? Эти функции точно так же возвращают Task. Который можно ждать через Result или Wait, блокируя поток, либо через await - не блокируя
    – Grundy
    Commented 16 янв. 2017 в 11:13
  • @Grundy, извиняюсь, перепутал с Task.WaitAll, Task.WaitAny. Вот только Task.WhenAny возвращает не Task<TResult>, а Task<Task<TResult>>. Может подскажите какую-либо UnWrap функцию, чтоб было удобнее?
    – Qutrix
    Commented 16 янв. 2017 в 11:39
  • Ну как я понимаю, тебе надо просто await использовать
    – Grundy
    Commented 16 янв. 2017 в 11:49

1 ответ 1

4

Вместо MagicFunction можно использовать функцию Task.WhenAll. Она вернет таск, который завершится тогда, когда завершатся все переданные таски. Результатом этого таска будет коллекция результатов переданных тасков. Тип коллекции зависит от используемой перегрузки, например, в данном случае результат будет массивом строк

static async Task<string[]> DoIt()
{
    Random r = new Random();
    Task<string> t1 = Task.Delay(r.Next(3000)).ContinueWith(t => "one");
    Task<string> t2 = Task.Delay(r.Next(3000)).ContinueWith(t => "two");

    return await Task.WhenAll(t1, t2); // вернет string[]
}

Для ожидания любого таска из переданных можно использовать функцию Task.WhenAny. Данный метод возвращает Task, результат которого - таск, который завершился.

static async Task<string> DoIt()
{
    Random r = new Random();
    Task<string> t1 = Task.Delay(r.Next(3000)).ContinueWith(t => "one");
    Task<string> t2 = Task.Delay(r.Next(3000)).ContinueWith(t => "two");

    var task = await Task.WhenAny(t1, t2); // вернет Task<string>
    return await task; // вернет string
}
1
  • 1
    // вернет string — или бросит исключение, если победивший таск завершился аварийно
    – VladD
    Commented 17 янв. 2017 в 23:05

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.