Task.WhenAll Método
Definição
Importante
Algumas informações dizem respeito a um produto pré-lançado que pode ser substancialmente modificado antes de ser lançado. A Microsoft não faz garantias, de forma expressa ou implícita, em relação à informação aqui apresentada.
Cria uma tarefa que será concluída quando todas as tarefas fornecidas estiverem concluídas.
Sobrecargas
| Name | Description |
|---|---|
| WhenAll(IEnumerable<Task>) |
Cria uma tarefa que será concluída quando todos os Task objetos de uma coleção enumerável estiverem concluídos. |
| WhenAll(Task[]) |
Cria uma tarefa que será concluída quando todos os Task objetos de um array estiverem concluídos. |
| WhenAll<TResult>(IEnumerable<Task<TResult>>) |
Cria uma tarefa que será concluída quando todos os Task<TResult> objetos de uma coleção enumerável estiverem concluídos. |
| WhenAll<TResult>(Task<TResult>[]) |
Cria uma tarefa que será concluída quando todos os Task<TResult> objetos de um array estiverem concluídos. |
WhenAll(IEnumerable<Task>)
Cria uma tarefa que será concluída quando todos os Task objetos de uma coleção enumerável estiverem concluídos.
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
Parâmetros
- tasks
- IEnumerable<Task>
As tarefas a esperar para serem concluídas.
Devoluções
Uma tarefa que representa a conclusão de todas as tarefas fornecidas.
Exceções
O tasks argumento era null.
A tasks coleção continha uma null tarefa.
Exemplos
O exemplo seguinte cria um conjunto de tarefas que fazem ping aos URLs num array. As tarefas são armazenadas numa List<Task> coleção que é passada ao WhenAll(IEnumerable<Task>) método. Depois de a chamada ao Wait método garantir que todas as threads foram concluídas, o exemplo examina a Task.Status propriedade para determinar se alguma tarefa teve falhas.
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
open System
open System.Net.NetworkInformation
open System.Threading
open System.Threading.Tasks
let mutable failed = 0
let urls =
[ "www.adatum.com"
"www.cohovineyard.com"
"www.cohowinery.com"
"www.northwindtraders.com"
"www.contoso.com" ]
let tasks =
urls
|> List.map (fun url ->
Task.Run(fun () ->
let png = new Ping()
try
let reply = png.Send url
if reply.Status <> IPStatus.Success then
Interlocked.Increment &failed |> ignore
raise (TimeoutException $"Unable to reach {url}.")
with :? PingException ->
Interlocked.Increment &failed |> ignore
reraise ()))
let t = Task.WhenAll tasks
try
t.Wait()
with _ ->
()
if t.Status = TaskStatus.RanToCompletion then
printfn "All ping attempts succeeded."
elif t.Status = TaskStatus.Faulted then
printfn $"{failed} ping attempts 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
Observações
As sobrecargas do WhenAll método que devolvem um Task objeto são normalmente chamadas quando se está interessado no estado de um conjunto de tarefas ou nas exceções lançadas por um conjunto de tarefas.
Note
O método chamada para WhenAll(IEnumerable<Task>) não bloqueia o thread que chama.
Se alguma das tarefas fornecidas for concluída num estado defeituoso, a tarefa devolvida também será concluída num Faulted estado, onde as suas exceções conterão a agregação do conjunto de exceções não desembrulhadas de cada uma das tarefas fornecidas.
Se nenhuma das tarefas fornecidas tiver falha mas pelo menos uma delas for cancelada, a tarefa devolvida termina nesse Canceled estado.
Se nenhuma das tarefas tiver falha e nenhuma delas for cancelada, a tarefa resultante termina nesse RanToCompletion estado.
Se o array/enumerável fornecido não contiver tarefas, a tarefa devolvida transitará imediatamente para um RanToCompletion estado antes de ser devolvida ao chamador.
Aplica-se a
WhenAll(Task[])
Cria uma tarefa que será concluída quando todos os Task objetos de um array estiverem concluídos.
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
Parâmetros
- tasks
- Task[]
As tarefas a esperar para serem concluídas.
Devoluções
Uma tarefa que representa a conclusão de todas as tarefas fornecidas.
Exceções
O tasks argumento era null.
A tasks matriz continha uma null tarefa.
Exemplos
O exemplo seguinte cria um conjunto de tarefas que fazem ping aos URLs num array. As tarefas são armazenadas numa List<Task> coleção que é convertida para um array e passada para o WhenAll(IEnumerable<Task>) método. Depois de a chamada ao Wait método garantir que todas as threads foram concluídas, o exemplo examina a Task.Status propriedade para determinar se alguma tarefa teve falhas.
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
open System
open System.Net.NetworkInformation
open System.Threading
open System.Threading.Tasks
let mutable failed = 0
let urls =
[| "www.adatum.com"
"www.cohovineyard.com"
"www.cohowinery.com"
"www.northwindtraders.com"
"www.contoso.com" |]
let tasks =
urls
|> Array.map (fun url ->
Task.Run(fun () ->
let png = new Ping()
try
let reply = png.Send url
if reply.Status <> IPStatus.Success then
Interlocked.Increment &failed |> ignore
raise (TimeoutException $"Unable to reach {url}.")
with :? PingException ->
Interlocked.Increment &failed |> ignore
reraise ()))
let main =
task {
let t = Task.WhenAll tasks
try
do! t
with _ ->
()
if t.Status = TaskStatus.RanToCompletion then
printfn "All ping attempts succeeded."
elif t.Status = TaskStatus.Faulted then
printfn $"{failed} ping attempts failed"
}
main.Wait()
// 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
Observações
As sobrecargas do WhenAll método que devolvem um Task objeto são normalmente chamadas quando se está interessado no estado de um conjunto de tarefas ou nas exceções lançadas por um conjunto de tarefas.
Note
O método chamada para WhenAll(Task[]) não bloqueia o thread que chama.
Se alguma das tarefas fornecidas for concluída num estado defeituoso, a tarefa devolvida também será concluída num Faulted estado, onde as suas exceções conterão a agregação do conjunto de exceções não desembrulhadas de cada uma das tarefas fornecidas.
Se nenhuma das tarefas fornecidas tiver falha mas pelo menos uma delas for cancelada, a tarefa devolvida termina nesse Canceled estado.
Se nenhuma das tarefas tiver falha e nenhuma delas for cancelada, a tarefa resultante termina nesse RanToCompletion estado.
Se o array/enumerável fornecido não contiver tarefas, a tarefa devolvida transitará imediatamente para um RanToCompletion estado antes de ser devolvida ao chamador.
Aplica-se a
WhenAll<TResult>(IEnumerable<Task<TResult>>)
Cria uma tarefa que será concluída quando todos os Task<TResult> objetos de uma coleção enumerável estiverem concluídos.
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())
Parâmetros de Tipo Genérico
- TResult
O tipo de tarefa concluída.
Parâmetros
- tasks
- IEnumerable<Task<TResult>>
As tarefas a esperar para serem concluídas.
Devoluções
Uma tarefa que representa a conclusão de todas as tarefas fornecidas.
Exceções
O tasks argumento era null.
A tasks coleção continha uma null tarefa.
Exemplos
O exemplo seguinte cria dez tarefas, cada uma das quais instancia um gerador de números aleatórios que cria 1.000 números aleatórios entre 1 e 1.000 e calcula a sua média. O Delay(Int32) método é usado para atrasar a instância dos geradores de números aleatórios para que não sejam criados com valores seed idênticos. A chamada ao WhenAll método devolve então um Int64 array que contém a média calculada por cada tarefa. Estes são então usados para calcular a média global.
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
open System
open System.Threading.Tasks
let tasks =
[| for i = 1 to 10 do
let delayInterval = 18 * i
task {
let mutable total = 0L
do! Task.Delay delayInterval
let rnd = Random()
for _ = 1 to 1000 do
total <- total + (rnd.Next(0, 1000) |> int64)
return total
} |]
let continuation = Task.WhenAll tasks
try
continuation.Wait()
with :? AggregateException ->
()
if continuation.Status = TaskStatus.RanToCompletion then
for result in continuation.Result do
printfn $"Mean: {float result / 1000.:N2}, n = 1,000"
let grandTotal = continuation.Result |> Array.sum
printfn $"\nMean of Means: {float grandTotal / 10000.:N2}, n = 10,000"
// Display information on faulted tasks.
else
for t in tasks do
printfn $"Task {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
Neste caso, as dez tarefas individuais são armazenadas num List<T> objeto. List<T> implementa a IEnumerable<T> interface.
Observações
O método chamada para WhenAll<TResult>(IEnumerable<Task<TResult>>) não bloqueia o thread que chama. No entanto, uma chamada à propriedade devolvida Result bloqueia o fio que chama.
Se alguma das tarefas fornecidas for concluída num estado defeituoso, a tarefa devolvida também será concluída num Faulted estado, onde as suas exceções conterão a agregação do conjunto de exceções não desembrulhadas de cada uma das tarefas fornecidas.
Se nenhuma das tarefas fornecidas tiver falha mas pelo menos uma delas for cancelada, a tarefa devolvida termina nesse Canceled estado.
Se nenhuma das tarefas tiver falha e nenhuma delas for cancelada, a tarefa resultante termina nesse RanToCompletion estado. A Task<TResult>.Result propriedade da tarefa devolvida será definida para um array contendo todos os resultados das tarefas fornecidas na mesma ordem em que foram fornecidos (por exemplo, se o array de tarefas de entrada contiver t1, t2, t3, a propriedade da Task<TResult>.Result tarefa de saída devolverá um TResult[] onde arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
Se o argumento tasks não contiver tarefas, a tarefa devolvida transitará imediatamente para um RanToCompletion estado antes de ser devolvida ao chamador. Os devolvidos TResult[] serão um array de 0 elementos.
Aplica-se a
WhenAll<TResult>(Task<TResult>[])
Cria uma tarefa que será concluída quando todos os Task<TResult> objetos de um array estiverem concluídos.
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())
Parâmetros de Tipo Genérico
- TResult
O tipo de tarefa concluída.
Parâmetros
- tasks
- Task<TResult>[]
As tarefas a esperar para serem concluídas.
Devoluções
Uma tarefa que representa a conclusão de todas as tarefas fornecidas.
Exceções
O tasks argumento era null.
A tasks matriz continha uma null tarefa.
Exemplos
O exemplo seguinte cria dez tarefas, cada uma das quais instancia um gerador de números aleatórios que cria 1.000 números aleatórios entre 1 e 1.000 e calcula a sua média. Neste caso, as dez tarefas individuais são armazenadas num Task<Int64> array. O Delay(Int32) método é usado para atrasar a instância dos geradores de números aleatórios para que não sejam criados com valores seed idênticos. A chamada ao WhenAll método devolve então um Int64 array que contém a média calculada por cada tarefa. Estes são então usados para calcular a média global.
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
open System
open System.Threading.Tasks
let tasks =
[| for i = 1 to 10 do
let delayInterval = 18 * i
task {
let mutable total = 0L
do! Task.Delay delayInterval
let rnd = Random()
for _ = 1 to 1000 do
total <- total + (rnd.Next(0, 1000) |> int64)
return total
} |]
let continuation = Task.WhenAll tasks
try
continuation.Wait()
with :? AggregateException ->
()
if continuation.Status = TaskStatus.RanToCompletion then
for result in continuation.Result do
printfn $"Mean: {float result / 1000.:N2}, n = 1,000"
let grandTotal = Array.sum continuation.Result
printfn $"\nMean of Means: {float grandTotal / 10000.:N2}, n = 10,000"
// Display information on faulted tasks.
else
for t in tasks do
printfn $"Task {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
Observações
O método chamada para WhenAll<TResult>(Task<TResult>[]) não bloqueia o thread que chama. No entanto, uma chamada à propriedade devolvida Result bloqueia o fio que chama.
Se alguma das tarefas fornecidas for concluída num estado defeituoso, a tarefa devolvida também será concluída num Faulted estado, onde as suas exceções conterão a agregação do conjunto de exceções não desembrulhadas de cada uma das tarefas fornecidas.
Se nenhuma das tarefas fornecidas tiver falha mas pelo menos uma delas for cancelada, a tarefa devolvida termina nesse Canceled estado.
Se nenhuma das tarefas tiver falha e nenhuma delas for cancelada, a tarefa resultante termina nesse RanToCompletion estado. O Result da tarefa devolvida será definido para um array contendo todos os resultados das tarefas fornecidas na mesma ordem em que foram fornecidas (por exemplo, se o array de tarefas de entrada contiver t1, t2, t3, as tarefas Result de saída devolverão um TResult[] onde arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
Se o array/enumerável fornecido não contiver tarefas, a tarefa devolvida transitará imediatamente para um RanToCompletion estado antes de ser devolvida ao chamador. Os devolvidos TResult[] serão um array de 0 elementos.