Task.WhenAll Metoda

Definice

Vytvoří úkol, který se dokončí po dokončení všech zadaných úkolů.

Přetížení

WhenAll(IEnumerable<Task>)

Vytvoří úlohu, která se dokončí, když se dokončí všechny Task objekty v výčtové kolekci.

WhenAll(Task[])

Vytvoří úlohu, která se dokončí po dokončení všech Task objektů v poli.

WhenAll<TResult>(IEnumerable<Task<TResult>>)

Vytvoří úlohu, která se dokončí, když se dokončí všechny Task<TResult> objekty v výčtové kolekci.

WhenAll<TResult>(Task<TResult>[])

Vytvoří úlohu, která se dokončí po dokončení všech Task<TResult> objektů v poli.

WhenAll(IEnumerable<Task>)

Vytvoří úlohu, která se dokončí, když se dokončí všechny Task objekty v výčtové kolekci.

public:
 static System::Threading::Tasks::Task ^ WhenAll(System::Collections::Generic::IEnumerable<System::Threading::Tasks::Task ^> ^ tasks);
public static System.Threading.Tasks.Task WhenAll (System.Collections.Generic.IEnumerable<System.Threading.Tasks.Task> tasks);
static member WhenAll : seq<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task
Public Shared Function WhenAll (tasks As IEnumerable(Of Task)) As Task

Parametry

tasks
IEnumerable<Task>

Úkoly, které budou čekat na dokončení.

Návraty

Task

Úkol, který představuje dokončení všech zadaných úkolů.

Výjimky

Argument tasks byl null.

Kolekce tasks obsahovala null úlohu.

Příklady

Následující příklad vytvoří sadu úkolů, které příkazem ping na adresy URL v poli. Úkoly jsou uloženy v List<Task> kolekci, která je předána WhenAll(IEnumerable<Task>) metodě. Po volání Wait metody zajistí, že všechna vlákna byla dokončena, příklad prozkoumá Task.Status vlastnost a určí, zda některé úlohy byly chybné.

using System;
using System.Collections.Generic;
using System.Net.NetworkInformation;
using System.Threading;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      int failed = 0;
      var tasks = new List<Task>();
      String[] urls = { "www.adatum.com", "www.cohovineyard.com",
                        "www.cohowinery.com", "www.northwindtraders.com",
                        "www.contoso.com" };
      
      foreach (var value in urls) {
         var url = value;
         tasks.Add(Task.Run( () => { var png = new Ping();
                                     try {
                                        var reply = png.Send(url);
                                        if (! (reply.Status == IPStatus.Success)) {
                                           Interlocked.Increment(ref failed);
                                           throw new TimeoutException("Unable to reach " + url + ".");
                                        }
                                     }
                                     catch (PingException) {
                                        Interlocked.Increment(ref failed);
                                        throw;
                                     }
                                   }));
      }
      Task t = Task.WhenAll(tasks);
      try {
         t.Wait();
      }
      catch {}   

      if (t.Status == TaskStatus.RanToCompletion)
         Console.WriteLine("All ping attempts succeeded.");
      else if (t.Status == TaskStatus.Faulted)
         Console.WriteLine("{0} ping attempts failed", failed);      
   }
}
// The example displays output like the following:
//       5 ping attempts failed
Imports System.Collections.Generic
Imports System.Net.NetworkInformation
Imports System.Threading
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim failed As Integer = 0
      Dim tasks As New List(Of Task)()
      Dim urls() As String = { "www.adatum.com", "www.cohovineyard.com",
                              "www.cohowinery.com", "www.northwindtraders.com",
                              "www.contoso.com" }
      
      For Each value In urls
         Dim url As String = value
         tasks.Add(Task.Run( Sub()
                                Dim png As New Ping()
                                Try
                                   Dim reply = png.Send(url)
                                   If Not reply.Status = IPStatus.Success Then
                                      Interlocked.Increment(failed)
                                      Throw New TimeoutException("Unable to reach " + url + ".")
                                   End If
                                   Catch e As PingException
                                      Interlocked.Increment(failed)
                                      Throw
                                   End Try
                             End Sub))
      Next
      Dim t As Task = Task.WhenAll(tasks)
      Try
         t.Wait()
      Catch
      End Try   

      If t.Status = TaskStatus.RanToCompletion
         Console.WriteLine("All ping attempts succeeded.")
      ElseIf t.Status = TaskStatus.Faulted
         Console.WriteLine("{0} ping attempts failed", failed)      
      End If
   End Sub
End Module
' The example displays output like the following:
'     5 ping attempts failed

Poznámky

Přetížení WhenAll metody, která vrací Task objekt, se obvykle volají, když máte zájem o stav sady úkolů nebo v výjimkách vyvolaných sadou úkolů.

Poznámka

Volání metody WhenAll(IEnumerable<Task>) neblokuje volající vlákno.

Pokud některý z zadaných úkolů skončí v chybném stavu, vrácený úkol se dokončí také ve Faulted stavu, kde jeho výjimky budou obsahovat agregaci sady nezabalených výjimek z každého zadaného úkolu.

Pokud žádný z zadaných úkolů nevyrušil, ale alespoň jeden z nich byl zrušen, vrácený úkol skončí ve Canceled stavu.

Pokud žádný z úkolů nevyrušil a žádný z úkolů nebyl zrušen, výsledný úkol skončí ve RanToCompletion stavu.

Pokud zadané pole nebo výčet neobsahuje žádné úkoly, vrácený úkol okamžitě přejde do RanToCompletion stavu, než se vrátí volajícímu.

Platí pro

WhenAll(Task[])

Vytvoří úlohu, která se dokončí po dokončení všech Task objektů v poli.

public:
 static System::Threading::Tasks::Task ^ WhenAll(... cli::array <System::Threading::Tasks::Task ^> ^ tasks);
public static System.Threading.Tasks.Task WhenAll (params System.Threading.Tasks.Task[] tasks);
static member WhenAll : System.Threading.Tasks.Task[] -> System.Threading.Tasks.Task
Public Shared Function WhenAll (ParamArray tasks As Task()) As Task

Parametry

tasks
Task[]

Úkoly, které budou čekat na dokončení.

Návraty

Task

Úkol, který představuje dokončení všech zadaných úkolů.

Výjimky

Argument tasks byl null.

Pole tasks obsahovalo null úkol.

Příklady

Následující příklad vytvoří sadu úkolů, které příkazem ping na adresy URL v poli. Úkoly jsou uloženy v List<Task> kolekci, která je převedena na pole a předána WhenAll(IEnumerable<Task>) metodě. Po volání Wait metody zajistí, že všechna vlákna byla dokončena, příklad prozkoumá Task.Status vlastnost a určí, zda některé úlohy byly chybné.

using System;
using System.Collections.Generic;
using System.Net.NetworkInformation;
using System.Threading;
using System.Threading.Tasks;

public class Example
{
   public static async Task Main()
   {
      int failed = 0;
      var tasks = new List<Task>();
      String[] urls = { "www.adatum.com", "www.cohovineyard.com",
                        "www.cohowinery.com", "www.northwindtraders.com",
                        "www.contoso.com" };
      
      foreach (var value in urls) {
         var url = value;
         tasks.Add(Task.Run( () => { var png = new Ping();
                                     try {
                                        var reply = png.Send(url);
                                        if (! (reply.Status == IPStatus.Success)) {
                                           Interlocked.Increment(ref failed);
                                           throw new TimeoutException("Unable to reach " + url + ".");
                                        }
                                     }
                                     catch (PingException) {
                                        Interlocked.Increment(ref failed);
                                        throw;
                                     }
                                   }));
      }
      Task t = Task.WhenAll(tasks.ToArray());
      try {
         await t;
      }
      catch {}   

      if (t.Status == TaskStatus.RanToCompletion)
         Console.WriteLine("All ping attempts succeeded.");
      else if (t.Status == TaskStatus.Faulted)
         Console.WriteLine("{0} ping attempts failed", failed);      
   }
}
// The example displays output like the following:
//       5 ping attempts failed
Imports System.Collections.Generic
Imports System.Net.NetworkInformation
Imports System.Threading
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim failed As Integer = 0
      Dim tasks As New List(Of Task)()
      Dim urls() As String = { "www.adatum.com", "www.cohovineyard.com",
                              "www.cohowinery.com", "www.northwindtraders.com",
                              "www.contoso.com" }
      
      For Each value In urls
         Dim url As String = value
         tasks.Add(Task.Run( Sub()
                                Dim png As New Ping()
                                Try
                                   Dim reply = png.Send(url)
                                   If Not reply.Status = IPStatus.Success Then
                                      Interlocked.Increment(failed)
                                      Throw New TimeoutException("Unable to reach " + url + ".")
                                   End If
                                   Catch e As PingException
                                      Interlocked.Increment(failed)
                                      Throw
                                   End Try
                             End Sub))
      Next
      Dim t As Task = Task.WhenAll(tasks.ToArray())
      Try
         t.Wait()
      Catch
      End Try   

      If t.Status = TaskStatus.RanToCompletion
         Console.WriteLine("All ping attempts succeeded.")
      ElseIf t.Status = TaskStatus.Faulted
         Console.WriteLine("{0} ping attempts failed", failed)      
      End If
   End Sub
End Module
' The example displays output like the following:
'     5 ping attempts failed

Poznámky

Přetížení WhenAll metody, která vrací Task objekt, se obvykle volají, když máte zájem o stav sady úkolů nebo v výjimkách vyvolaných sadou úkolů.

Poznámka

Volání metody WhenAll(Task[]) neblokuje volající vlákno.

Pokud některý z zadaných úkolů skončí v chybném stavu, vrácený úkol se dokončí také ve Faulted stavu, kde jeho výjimky budou obsahovat agregaci sady nezabalených výjimek z každého zadaného úkolu.

Pokud žádný z zadaných úkolů nevyrušil, ale alespoň jeden z nich byl zrušen, vrácený úkol skončí ve Canceled stavu.

Pokud žádný z úkolů nevyrušil a žádný z úkolů nebyl zrušen, výsledný úkol skončí ve RanToCompletion stavu.

Pokud zadané pole nebo výčet neobsahuje žádné úkoly, vrácený úkol okamžitě přejde do RanToCompletion stavu, než se vrátí volajícímu.

Platí pro

WhenAll<TResult>(IEnumerable<Task<TResult>>)

Vytvoří úlohu, která se dokončí, když se dokončí všechny Task<TResult> objekty v výčtové kolekci.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<cli::array <TResult> ^> ^ WhenAll(System::Collections::Generic::IEnumerable<System::Threading::Tasks::Task<TResult> ^> ^ tasks);
public static System.Threading.Tasks.Task<TResult[]> WhenAll<TResult> (System.Collections.Generic.IEnumerable<System.Threading.Tasks.Task<TResult>> tasks);
static member WhenAll : seq<System.Threading.Tasks.Task<'Result>> -> System.Threading.Tasks.Task<'Result[]>
Public Shared Function WhenAll(Of TResult) (tasks As IEnumerable(Of Task(Of TResult))) As Task(Of TResult())

Parametry typu

TResult

Typ dokončeného úkolu.

Parametry

tasks
IEnumerable<Task<TResult>>

Úkoly, které budou čekat na dokončení.

Návraty

Task<TResult[]>

Úkol, který představuje dokončení všech zadaných úkolů.

Výjimky

Argument tasks byl null.

Kolekce tasks obsahovala null úlohu.

Příklady

Následující příklad vytvoří deset úkolů, z nichž každý vytvoří instanci generátoru náhodných čísel, který vytvoří 1 000 náhodných čísel mezi 1 a 1 000 a vypočítá jejich průměr. Metoda Delay(Int32) se používá ke zpoždění vytváření instancí generátorů náhodných čísel tak, aby nebyly vytvořeny se stejnými počátečními hodnotami. Volání WhenAll metody pak vrátí Int64 pole, které obsahuje střední hodnotu vypočítanou jednotlivými úlohami. Tyto hodnoty se pak použijí k výpočtu celkového průměru.

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      var tasks = new List<Task<long>>();
      for (int ctr = 1; ctr <= 10; ctr++) {
         int delayInterval = 18 * ctr;
         tasks.Add(Task.Run(async () => { long total = 0;
                                          await Task.Delay(delayInterval);
                                          var rnd = new Random();
                                          // Generate 1,000 random numbers.
                                          for (int n = 1; n <= 1000; n++)
                                             total += rnd.Next(0, 1000);
                                          return total; } ));
      }
      var continuation = Task.WhenAll(tasks);
      try {
         continuation.Wait();
      }
      catch (AggregateException)
      { }
   
      if (continuation.Status == TaskStatus.RanToCompletion) {
         long grandTotal = 0;
         foreach (var result in continuation.Result) {
            grandTotal += result;
            Console.WriteLine("Mean: {0:N2}, n = 1,000", result/1000.0);
         }
   
         Console.WriteLine("\nMean of Means: {0:N2}, n = 10,000",
                           grandTotal/10000);
      }
      // Display information on faulted tasks.
      else {
         foreach (var t in tasks) {
            Console.WriteLine("Task {0}: {1}", t.Id, t.Status);
         }
      }
   }
}
// The example displays output like the following:
//       Mean: 506.34, n = 1,000
//       Mean: 504.69, n = 1,000
//       Mean: 489.32, n = 1,000
//       Mean: 505.96, n = 1,000
//       Mean: 515.31, n = 1,000
//       Mean: 499.94, n = 1,000
//       Mean: 496.92, n = 1,000
//       Mean: 508.58, n = 1,000
//       Mean: 494.88, n = 1,000
//       Mean: 493.53, n = 1,000
//
//       Mean of Means: 501.55, n = 10,000
Imports System.Collections.Generic
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim tasks As New List(Of Task(Of Long))()
      For ctr As Integer = 1 To 10
         Dim delayInterval As Integer = 18 * ctr
         tasks.Add(Task.Run(Async Function()
                               Dim total As Long = 0
                               Await Task.Delay(delayInterval)
                               Dim rnd As New Random()
                               ' Generate 1,000 random numbers.
                               For n As Integer = 1 To 1000
                                  total += rnd.Next(0, 1000)
                               Next
                               Return total
                            End Function))
      Next
      Dim continuation = Task.WhenAll(tasks)
      Try
         continuation.Wait()
      Catch ae As AggregateException
      End Try
      
      If continuation.Status = TaskStatus.RanToCompletion Then
         Dim grandTotal As Long = 0
         For Each result in continuation.Result
            grandTotal += result
            Console.WriteLine("Mean: {0:N2}, n = 1,000", result/1000)
         Next
         Console.WriteLine()
         Console.WriteLine("Mean of Means: {0:N2}, n = 10,000",
                           grandTotal/10000)
      ' Display information on faulted tasks.
      Else 
         For Each t In tasks
            Console.WriteLine("Task {0}: {1}", t.Id, t.Status)
         Next
      End If
   End Sub
End Module
' The example displays output like the following:
'       Mean: 506.34, n = 1,000
'       Mean: 504.69, n = 1,000
'       Mean: 489.32, n = 1,000
'       Mean: 505.96, n = 1,000
'       Mean: 515.31, n = 1,000
'       Mean: 499.94, n = 1,000
'       Mean: 496.92, n = 1,000
'       Mean: 508.58, n = 1,000
'       Mean: 494.88, n = 1,000
'       Mean: 493.53, n = 1,000
'
'       Mean of Means: 501.55, n = 10,000

V tomto případě jsou deset jednotlivých úkolů uloženy v objektu List<T> . List<T> implementuje IEnumerable<T> rozhraní.

Poznámky

Volání metody WhenAll<TResult>(IEnumerable<Task<TResult>>) neblokuje volající vlákno. Volání vrácené Result vlastnosti však blokuje volající vlákno.

Pokud některý z zadaných úkolů skončí v chybném stavu, vrácený úkol se dokončí také ve Faulted stavu, kde jeho výjimky budou obsahovat agregaci sady nezabalených výjimek z každého zadaného úkolu.

Pokud žádný z zadaných úkolů nevyrušil, ale alespoň jeden z nich byl zrušen, vrácený úkol skončí ve Canceled stavu.

Pokud žádný z úkolů nevyrušil a žádný z úkolů nebyl zrušen, výsledný úkol skončí ve RanToCompletion stavu. Vlastnost Task<TResult>.Result vráceného úkolu bude nastavena na pole obsahující všechny výsledky zadaných úkolů ve stejném pořadí, v jakém byly zadány (například pokud vstupní pole úkolů obsahovalo t1, t2, t3, vrátí TResult[] vlastnost výstupního úkolu Task<TResult>.Result místo arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).

tasks Pokud argument neobsahuje žádné úkoly, vrácený úkol okamžitě přejde do RanToCompletion stavu, než se vrátí volajícímu. TResult[] Vrácená hodnota bude matice 0 prvků.

Platí pro

WhenAll<TResult>(Task<TResult>[])

Vytvoří úlohu, která se dokončí po dokončení všech Task<TResult> objektů v poli.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<cli::array <TResult> ^> ^ WhenAll(... cli::array <System::Threading::Tasks::Task<TResult> ^> ^ tasks);
public static System.Threading.Tasks.Task<TResult[]> WhenAll<TResult> (params System.Threading.Tasks.Task<TResult>[] tasks);
static member WhenAll : System.Threading.Tasks.Task<'Result>[] -> System.Threading.Tasks.Task<'Result[]>
Public Shared Function WhenAll(Of TResult) (ParamArray tasks As Task(Of TResult)()) As Task(Of TResult())

Parametry typu

TResult

Typ dokončeného úkolu.

Parametry

tasks
Task<TResult>[]

Úkoly, které budou čekat na dokončení.

Návraty

Task<TResult[]>

Úkol, který představuje dokončení všech zadaných úkolů.

Výjimky

Argument tasks byl null.

Pole tasks obsahovalo null úkol.

Příklady

Následující příklad vytvoří deset úkolů, z nichž každý vytvoří instanci generátoru náhodných čísel, který vytvoří 1 000 náhodných čísel mezi 1 a 1 000 a vypočítá jejich průměr. V tomto případě se deset jednotlivých úkolů uloží do Task<Int64> pole. Metoda Delay(Int32) se používá ke zpoždění vytváření instancí generátorů náhodných čísel tak, aby nebyly vytvořeny se stejnými počátečními hodnotami. Volání WhenAll metody pak vrátí Int64 pole, které obsahuje střední hodnotu vypočítanou jednotlivými úlohami. Tyto hodnoty se pak použijí k výpočtu celkového průměru.

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      var tasks = new Task<long>[10];
      for (int ctr = 1; ctr <= 10; ctr++) {
         int delayInterval = 18 * ctr;
         tasks[ctr - 1] = Task.Run(async () => { long total = 0;
                                                 await Task.Delay(delayInterval);
                                                 var rnd = new Random();
                                                 // Generate 1,000 random numbers.
                                                 for (int n = 1; n <= 1000; n++)
                                                    total += rnd.Next(0, 1000);

                                                 return total; } );
      }
      var continuation = Task.WhenAll(tasks);
      try {
         continuation.Wait();
      }
      catch (AggregateException)
      {}
   
      if (continuation.Status == TaskStatus.RanToCompletion) {
         long grandTotal = 0;
         foreach (var result in continuation.Result) {
            grandTotal += result;
            Console.WriteLine("Mean: {0:N2}, n = 1,000", result/1000.0);
         }
   
         Console.WriteLine("\nMean of Means: {0:N2}, n = 10,000",
                           grandTotal/10000);
      }
      // Display information on faulted tasks.
      else { 
         foreach (var t in tasks)
            Console.WriteLine("Task {0}: {1}", t.Id, t.Status);
      }
   }
}
// The example displays output like the following:
//       Mean: 506.38, n = 1,000
//       Mean: 501.01, n = 1,000
//       Mean: 505.36, n = 1,000
//       Mean: 492.00, n = 1,000
//       Mean: 508.36, n = 1,000
//       Mean: 503.99, n = 1,000
//       Mean: 504.95, n = 1,000
//       Mean: 508.58, n = 1,000
//       Mean: 490.23, n = 1,000
//       Mean: 501.59, n = 1,000
//
//       Mean of Means: 502.00, n = 10,000
Imports System.Collections.Generic
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim tasks(9) As Task(Of Long)
      For ctr As Integer = 1 To 10
         Dim delayInterval As Integer = 18 * ctr
         tasks(ctr - 1) =Task.Run(Async Function()
                                     Dim total As Long = 0
                                     Await Task.Delay(delayInterval)
                                     Dim rnd As New Random()
                                     ' Generate 1,000 random numbers.
                                     For n As Integer = 1 To 1000
                                        total += rnd.Next(0, 1000)
                                     Next
                                     Return total
                                  End Function)
      Next
      Dim continuation = Task.WhenAll(tasks)
      Try
         continuation.Wait()
      Catch ae As AggregateException
      End Try
         
      If continuation.Status = TaskStatus.RanToCompletion Then
         Dim grandTotal As Long = 0
         For Each result in continuation.Result
            grandTotal += result
            Console.WriteLine("Mean: {0:N2}, n = 1,000", result/1000)
         Next
         Console.WriteLine()
         Console.WriteLine("Mean of Means: {0:N2}, n = 10,000",
                           grandTotal/10000)
      ' Display information on faulted tasks.
      Else 
         For Each t In tasks
            Console.WriteLine("Task {0}: {1}", t.Id, t.Status)
         Next
      End If
   End Sub
End Module
' The example displays output like the following:
'       Mean: 506.38, n = 1,000
'       Mean: 501.01, n = 1,000
'       Mean: 505.36, n = 1,000
'       Mean: 492.00, n = 1,000
'       Mean: 508.36, n = 1,000
'       Mean: 503.99, n = 1,000
'       Mean: 504.95, n = 1,000
'       Mean: 508.58, n = 1,000
'       Mean: 490.23, n = 1,000
'       Mean: 501.59, n = 1,000
'
'       Mean of Means: 502.00, n = 10,000

Poznámky

Volání metody WhenAll<TResult>(Task<TResult>[]) neblokuje volající vlákno. Volání vrácené Result vlastnosti však blokuje volající vlákno.

Pokud některý z zadaných úkolů skončí v chybném stavu, vrácený úkol se dokončí také ve Faulted stavu, kde jeho výjimky budou obsahovat agregaci sady nezabalených výjimek z každého zadaného úkolu.

Pokud žádný z zadaných úkolů nevyrušil, ale alespoň jeden z nich byl zrušen, vrácený úkol skončí ve Canceled stavu.

Pokud žádný z úkolů nevyrušil a žádný z úkolů nebyl zrušen, výsledný úkol skončí ve RanToCompletion stavu. Vrácený Result úkol bude nastaven na pole obsahující všechny výsledky zadaných úkolů ve stejném pořadí, v jakém byly zadány (např. pokud vstupní pole úkolů obsahovalo t1, t2, t3, vrátí TResult[] výstupní úkol Result místo arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).

Pokud zadané pole nebo výčet neobsahuje žádné úkoly, vrácený úkol okamžitě přejde do RanToCompletion stavu, než se vrátí volajícímu. TResult[] Vrácená hodnota bude matice 0 prvků.

Platí pro