Task.WhenAll Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Создает задачу, которая завершится после завершения всех предоставленных задач.
Перегрузки
| WhenAll(IEnumerable<Task>) |
Создает задачу, которая завершится после завершения всех объектов Task в перечисленной коллекции. |
| WhenAll(ReadOnlySpan<Task>) |
Создает задачу, которая завершится после завершения всех предоставленных задач. |
| WhenAll(Task[]) |
Создает задачу, которая завершится, когда все объекты Task в массиве завершены. |
| WhenAll<TResult>(ReadOnlySpan<Task<TResult>>) |
Создает задачу, которая завершится после завершения всех предоставленных задач. |
| WhenAll<TResult>(IEnumerable<Task<TResult>>) |
Создает задачу, которая завершится после завершения всех объектов Task<TResult> в перечисленной коллекции. |
| WhenAll<TResult>(Task<TResult>[]) |
Создает задачу, которая завершится, когда все объекты Task<TResult> в массиве завершены. |
WhenAll(IEnumerable<Task>)
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
Создает задачу, которая завершится после завершения всех объектов Task в перечисленной коллекции.
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.TaskPublic Shared Function WhenAll (tasks As IEnumerable(Of Task)) As TaskПараметры
- tasks
- IEnumerable<Task>
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Аргумент tasks был null.
Коллекция tasks содержала задачу null.
Примеры
В следующем примере создается набор задач, которые выполняют связь с URL-адресами в массиве. Задачи хранятся в коллекции List<Task>, передаваемой методу WhenAll(IEnumerable<Task>). После вызова метода Wait убедитесь, что все потоки завершены, в примере проверяется свойство Task.Status, чтобы определить, были ли выполнены какие-либо задачи.
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
Комментарии
Перегрузки метода WhenAll, возвращающего объект Task, обычно вызываются при интересе к состоянию набора задач или в исключениях, создаваемых набором задач.
Заметка
Вызов метода WhenAll(IEnumerable<Task>) не блокирует вызывающий поток.
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии Faulted, где его исключения будут содержать агрегирование набора несвоеженных исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии Canceled.
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion.
Если предоставленный массив или перечисление не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion до возвращения вызывающему объекту.
Применяется к
WhenAll(ReadOnlySpan<Task>)
Создает задачу, которая завершится после завершения всех предоставленных задач.
public:
static System::Threading::Tasks::Task ^ WhenAll(ReadOnlySpan<System::Threading::Tasks::Task ^> tasks);public static System.Threading.Tasks.Task WhenAll (scoped ReadOnlySpan<System.Threading.Tasks.Task> tasks);static member WhenAll : ReadOnlySpan<System.Threading.Tasks.Task> -> System.Threading.Tasks.TaskPublic Shared Function WhenAll (tasks As ReadOnlySpan(Of Task)) As TaskПараметры
- tasks
- ReadOnlySpan<Task>
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Массив tasks содержит задачу null.
Комментарии
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии сбоя, где его исключения будут содержать агрегирование набора нескрытых исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии "Отменено".
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion.
Если предоставленный диапазон не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion, прежде чем он возвращается вызывающему объекту.
Применяется к
WhenAll(Task[])
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
Создает задачу, которая завершится, когда все объекты Task в массиве завершены.
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.TaskPublic Shared Function WhenAll (ParamArray tasks As Task()) As TaskПараметры
- tasks
- Task[]
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Аргумент tasks был null.
Массив tasks содержал задачу null.
Примеры
В следующем примере создается набор задач, которые выполняют связь с URL-адресами в массиве. Задачи хранятся в коллекции List<Task>, которая преобразуется в массив и передается в метод WhenAll(IEnumerable<Task>). После вызова метода Wait убедитесь, что все потоки завершены, в примере проверяется свойство Task.Status, чтобы определить, были ли выполнены какие-либо задачи.
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
Комментарии
Перегрузки метода WhenAll, возвращающего объект Task, обычно вызываются при интересе к состоянию набора задач или в исключениях, создаваемых набором задач.
Заметка
Вызов метода WhenAll(Task[]) не блокирует вызывающий поток.
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии Faulted, где его исключения будут содержать агрегирование набора несвоеженных исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии Canceled.
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion.
Если предоставленный массив или перечисление не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion до возвращения вызывающему объекту.
Применяется к
WhenAll<TResult>(ReadOnlySpan<Task<TResult>>)
Создает задачу, которая завершится после завершения всех предоставленных задач.
public:
generic <typename TResult>
static System::Threading::Tasks::Task<cli::array <TResult> ^> ^ WhenAll(ReadOnlySpan<System::Threading::Tasks::Task<TResult> ^> tasks);public static System.Threading.Tasks.Task<TResult[]> WhenAll<TResult> (scoped ReadOnlySpan<System.Threading.Tasks.Task<TResult>> tasks);static member WhenAll : ReadOnlySpan<System.Threading.Tasks.Task<'Result>> -> System.Threading.Tasks.Task<'Result[]>Public Shared Function WhenAll(Of TResult) (tasks As ReadOnlySpan(Of Task(Of TResult))) As Task(Of TResult())Параметры типа
- TResult
Параметры
- tasks
- ReadOnlySpan<Task<TResult>>
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Массив tasks содержит задачу null.
Комментарии
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии сбоя, где его исключения будут содержать агрегирование набора нескрытых исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии "Отменено".
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion. Результат возвращаемой задачи будет иметь массив, содержащий все результаты предоставленных задач в том же порядке, что и предоставленные (например, если массив входных задач содержит t1, t2, t3, результат выходной задачи возвращает TResult[] где arr[0] == t1. Результат, arr[1] == t2. Результат и arr[2] == t3. Результат).
Если предоставленный массив или перечисление не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion до возвращения вызывающему объекту. Возвращенный TResult[] будет массивом элементов 0.
Применяется к
WhenAll<TResult>(IEnumerable<Task<TResult>>)
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
Создает задачу, которая завершится после завершения всех объектов Task<TResult> в перечисленной коллекции.
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())Параметры типа
- TResult
Тип завершенной задачи.
Параметры
- tasks
- IEnumerable<Task<TResult>>
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Аргумент tasks был null.
Коллекция tasks содержала задачу null.
Примеры
В следующем примере создаются десять задач, каждый из которых создает генератор случайных чисел, который создает 1000 случайных чисел от 1 до 1000 и вычисляет их среднее значение. Метод Delay(Int32) используется для задержки создания экземпляров генераторов случайных чисел, чтобы они не создавались с одинаковыми начальными значениями. Вызов метода WhenAll затем возвращает массив Int64, содержащий средний вычисляемый каждой задачей массив. Затем они используются для вычисления общего среднего значения.
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
В этом случае десять отдельных задач хранятся в объекте List<T>. List<T> реализует интерфейс IEnumerable<T>.
Комментарии
Вызов метода WhenAll<TResult>(IEnumerable<Task<TResult>>) не блокирует вызывающий поток. Однако вызов возвращаемого свойства Result блокирует вызывающий поток.
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии Faulted, где его исключения будут содержать агрегирование набора несвоеженных исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии Canceled.
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion. Свойство Task<TResult>.Result возвращаемой задачи будет иметь массив, содержащий все результаты предоставленных задач в том же порядке, что и предоставленные (например, если массив входных задач содержит t1, t2, t3, свойство Task<TResult>.Result задачи вывода возвращает TResult[], где arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
Если аргумент tasks не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion до возвращения вызывающему объекту. Возвращенный TResult[] будет массивом элементов 0.
Применяется к
WhenAll<TResult>(Task<TResult>[])
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
- Исходный код:
- Task.cs
Создает задачу, которая завершится, когда все объекты Task<TResult> в массиве завершены.
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())Параметры типа
- TResult
Тип завершенной задачи.
Параметры
- tasks
- Task<TResult>[]
Задачи, которые нужно ждать завершения.
Возвращаемое значение
Задача, представляющая завершение всех предоставленных задач.
Исключения
Аргумент tasks был null.
Массив tasks содержал задачу null.
Примеры
В следующем примере создаются десять задач, каждый из которых создает генератор случайных чисел, который создает 1000 случайных чисел от 1 до 1000 и вычисляет их среднее значение. В этом случае десять отдельных задач хранятся в массиве Task<Int64>. Метод Delay(Int32) используется для задержки создания экземпляров генераторов случайных чисел, чтобы они не создавались с одинаковыми начальными значениями. Вызов метода WhenAll затем возвращает массив Int64, содержащий средний вычисляемый каждой задачей массив. Затем они используются для вычисления общего среднего значения.
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
Комментарии
Вызов метода WhenAll<TResult>(Task<TResult>[]) не блокирует вызывающий поток. Однако вызов возвращаемого свойства Result блокирует вызывающий поток.
Если какая-либо из указанных задач завершается в состоянии сбоя, возвращаемая задача также завершится в состоянии Faulted, где его исключения будут содержать агрегирование набора несвоеженных исключений из каждой из указанных задач.
Если ни одна из предоставленных задач не была выполнена сбоем, но по крайней мере одна из них была отменена, возвращенная задача завершится в состоянии Canceled.
Если ни одна из задач не выполнена, и ни одна из задач не была отменена, результирующая задача завершится в состоянии RanToCompletion.
Result возвращаемой задачи будет задан массив, содержащий все результаты предоставленных задач в том же порядке, что и предоставленные (например, если массив входных задач содержит t1, t3, Result задачи вывода возвращает TResult[], где arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
Если предоставленный массив или перечисление не содержит никаких задач, возвращаемая задача немедленно перейдет в состояние RanToCompletion до возвращения вызывающему объекту. Возвращенный TResult[] будет массивом элементов 0.
Применяется к
Кері байланыс
Жақында қолжетімді болады: 2024 жыл бойы біз GitHub Issues жүйесін мазмұнға арналған кері байланыс механизмі ретінде біртіндеп қолданыстан шығарамыз және оны жаңа кері байланыс жүйесімен ауыстырамыз. Қосымша ақпаратты мұнда қараңыз: https://aka.ms/ContentUserFeedback.
Жіберу және пікірді көру