Task.WhenAll Méthode
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Crée une tâche qui s'achève lorsque toutes les tâches fournies sont terminées.
Surcharges
WhenAll(IEnumerable<Task>) |
Crée une tâche qui s’achève quand tous les objets Task d’une collection énumérable sont terminés. |
WhenAll(Task[]) |
Crée une tâche qui s’achève quand tous les objets Task d’un tableau sont terminés. |
WhenAll<TResult>(IEnumerable<Task<TResult>>) |
Crée une tâche qui s’achève quand tous les objets Task<TResult> d’une collection énumérable sont terminés. |
WhenAll<TResult>(Task<TResult>[]) |
Crée une tâche qui s’achève quand tous les objets Task<TResult> d’un tableau sont terminés. |
WhenAll(IEnumerable<Task>)
Crée une tâche qui s’achève quand tous les objets Task d’une collection énumérable sont terminés.
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
Paramètres
- tasks
- IEnumerable<Task>
Tâches restantes à exécuter avant la fin.
Retours
Tâche qui représente l’achèvement de toutes les tâches fournies.
Exceptions
L’argument tasks
avait la valeur null
.
La collection de tasks
contenait une tâche null
.
Exemples
L’exemple suivant crée un ensemble de tâches qui effectuent un test ping sur les URL d’un tableau. Les tâches sont stockées dans une List<Task>
collection passée à la WhenAll(IEnumerable<Task>) méthode. Une fois l’appel à la Wait méthode effectué, l’exemple examine la Task.Status propriété pour déterminer si des tâches ont été défectueuses.
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
Remarques
Les surcharges de la WhenAll méthode qui retournent un Task objet sont généralement appelées lorsque vous êtes intéressé par l’état d’un ensemble de tâches ou dans les exceptions levées par un ensemble de tâches.
Notes
L’appel à la WhenAll(IEnumerable<Task>) méthode ne bloque pas le thread appelant.
Si l’une des tâches fournies se termine dans un état d’erreur, la tâche retournée se termine également dans un Faulted état, où ses exceptions contiennent l’agrégation de l’ensemble d’exceptions non extraites de chacune des tâches fournies.
Si aucune des tâches fournies n’a été défectueuse, mais qu’au moins l’une d’elles a été annulée, la tâche retournée se termine dans l’état Canceled .
Si aucune des tâches n’a été défectueuse et qu’aucune des tâches n’a été annulée, la tâche résultante se termine par l’état RanToCompletion .
Si le tableau/énumérable fourni ne contient aucune tâche, la tâche retournée passe immédiatement à un RanToCompletion état avant qu’elle ne soit retournée à l’appelant.
S’applique à
WhenAll(Task[])
Crée une tâche qui s’achève quand tous les objets Task d’un tableau sont terminés.
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
Paramètres
- tasks
- Task[]
Tâches restantes à exécuter avant la fin.
Retours
Tâche qui représente l’achèvement de toutes les tâches fournies.
Exceptions
L’argument tasks
avait la valeur null
.
Le tableau tasks
contenait une tâche null
.
Exemples
L’exemple suivant crée un ensemble de tâches qui effectuent un test ping sur les URL d’un tableau. Les tâches sont stockées dans une List<Task>
collection convertie en tableau et passées à la WhenAll(IEnumerable<Task>) méthode. Une fois l’appel à la Wait méthode effectué, l’exemple examine la Task.Status propriété pour déterminer si des tâches ont été défectueuses.
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
Remarques
Les surcharges de la WhenAll méthode qui retournent un Task objet sont généralement appelées lorsque vous êtes intéressé par l’état d’un ensemble de tâches ou dans les exceptions levées par un ensemble de tâches.
Notes
L’appel à la WhenAll(Task[]) méthode ne bloque pas le thread appelant.
Si l’une des tâches fournies se termine dans un état d’erreur, la tâche retournée se termine également dans un Faulted état, où ses exceptions contiennent l’agrégation de l’ensemble d’exceptions non extraites de chacune des tâches fournies.
Si aucune des tâches fournies n’a été défectueuse, mais qu’au moins l’une d’elles a été annulée, la tâche retournée se termine dans l’état Canceled .
Si aucune des tâches n’a été défectueuse et qu’aucune des tâches n’a été annulée, la tâche résultante se termine par l’état RanToCompletion .
Si le tableau/énumérable fourni ne contient aucune tâche, la tâche retournée passe immédiatement à un RanToCompletion état avant qu’elle ne soit retournée à l’appelant.
S’applique à
WhenAll<TResult>(IEnumerable<Task<TResult>>)
Crée une tâche qui s’achève quand tous les objets Task<TResult> d’une collection énumérable sont terminés.
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())
Paramètres de type
- TResult
Type de la tâche terminée.
Paramètres
- tasks
- IEnumerable<Task<TResult>>
Tâches restantes à exécuter avant la fin.
Retours
- Task<TResult[]>
Tâche qui représente l’achèvement de toutes les tâches fournies.
Exceptions
L’argument tasks
avait la valeur null
.
La collection tasks
contenait une tâche null
.
Exemples
L’exemple suivant crée dix tâches, chacune instanciant un générateur de nombres aléatoires qui crée 1 000 nombres aléatoires compris entre 1 et 1 000 et calcule leur moyenne. La Delay(Int32) méthode est utilisée pour retarder l’instanciation des générateurs de nombres aléatoires afin qu’elles ne soient pas créées avec des valeurs initiales identiques. L’appel à la WhenAll méthode retourne ensuite un Int64 tableau qui contient la moyenne calculée par chaque tâche. Ils sont ensuite utilisés pour calculer la moyenne globale.
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
Dans ce cas, les dix tâches individuelles sont stockées dans un List<T> objet. List<T> implémente l'interface IEnumerable<T>.
Remarques
L’appel à la WhenAll<TResult>(IEnumerable<Task<TResult>>) méthode ne bloque pas le thread appelant. Toutefois, un appel à la propriété retournée Result bloque le thread appelant.
Si l’une des tâches fournies se termine dans un état d’erreur, la tâche retournée se termine également dans un Faulted état, où ses exceptions contiennent l’agrégation de l’ensemble d’exceptions non extraites de chacune des tâches fournies.
Si aucune des tâches fournies n’a été défectueuse, mais qu’au moins l’une d’elles a été annulée, la tâche retournée se termine dans l’état Canceled .
Si aucune des tâches n’a été défectueuse et qu’aucune des tâches n’a été annulée, la tâche résultante se termine par l’état RanToCompletion . La Task<TResult>.Result propriété de la tâche retournée est définie sur un tableau contenant tous les résultats des tâches fournies dans le même ordre qu’ils ont été fournis (par exemple, si le tableau des tâches d’entrée contenait t1, t2, t3, la propriété de la tâche de Task<TResult>.Result sortie retourne un TResult[]
emplacement où arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)
.
Si l’argument tasks
ne contient aucune tâche, la tâche retournée passe immédiatement à un RanToCompletion état avant qu’elle ne soit retournée à l’appelant. Le retour TResult[]
sera un tableau de 0 éléments.
S’applique à
WhenAll<TResult>(Task<TResult>[])
Crée une tâche qui s’achève quand tous les objets Task<TResult> d’un tableau sont terminés.
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())
Paramètres de type
- TResult
Type de la tâche terminée.
Paramètres
- tasks
- Task<TResult>[]
Tâches restantes à exécuter avant la fin.
Retours
- Task<TResult[]>
Tâche qui représente l’achèvement de toutes les tâches fournies.
Exceptions
L’argument tasks
avait la valeur null
.
Le tableau de tasks
contenait une tâche null
.
Exemples
L’exemple suivant crée dix tâches, chacune instanciant un générateur de nombres aléatoires qui crée 1 000 nombres aléatoires compris entre 1 et 1 000 et calcule leur moyenne. Dans ce cas, les dix tâches individuelles sont stockées dans un Task<Int64>
tableau. La Delay(Int32) méthode est utilisée pour retarder l’instanciation des générateurs de nombres aléatoires afin qu’elles ne soient pas créées avec des valeurs initiales identiques. L’appel à la WhenAll méthode retourne ensuite un Int64 tableau qui contient la moyenne calculée par chaque tâche. Ils sont ensuite utilisés pour calculer la moyenne globale.
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
Remarques
L’appel à la WhenAll<TResult>(Task<TResult>[]) méthode ne bloque pas le thread appelant. Toutefois, un appel à la propriété retournée Result bloque le thread appelant.
Si l’une des tâches fournies se termine dans un état d’erreur, la tâche retournée se termine également dans un Faulted état, où ses exceptions contiennent l’agrégation de l’ensemble d’exceptions non extraites de chacune des tâches fournies.
Si aucune des tâches fournies n’a été défectueuse, mais qu’au moins l’une d’elles a été annulée, la tâche retournée se termine dans l’état Canceled .
Si aucune des tâches n’a été défectueuse et qu’aucune des tâches n’a été annulée, la tâche résultante se termine par l’état RanToCompletion . La Result tâche retournée est définie sur un tableau contenant tous les résultats des tâches fournies dans le même ordre qu’ils ont été fournis (par exemple, si le tableau des tâches d’entrée contenait t1, t2, t3, la tâche de Result sortie retourne un TResult[]
emplacement où arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)
.
Si le tableau/énumérable fourni ne contient aucune tâche, la tâche retournée passe immédiatement à un RanToCompletion état avant qu’elle ne soit retournée à l’appelant. Le retour TResult[]
sera un tableau de 0 éléments.