Task.WhenAll Yöntem
Tanım
Önemli
Bazı bilgiler ürünün ön sürümüyle ilgilidir ve sürüm öncesinde önemli değişiklikler yapılmış olabilir. Burada verilen bilgilerle ilgili olarak Microsoft açık veya zımni hiçbir garanti vermez.
Sağlanan tüm görevler tamamlandığında tamamlanacak bir görev oluşturur.
Aşırı Yüklemeler
| WhenAll(IEnumerable<Task>) |
Numaralandırılabilir bir koleksiyondaki Task tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur. |
| WhenAll(Task[]) |
Bir dizideki Task tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur. |
| WhenAll<TResult>(IEnumerable<Task<TResult>>) |
Numaralandırılabilir bir koleksiyondaki Task<TResult> tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur. |
| WhenAll<TResult>(Task<TResult>[]) |
Bir dizideki Task<TResult> tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur. |
WhenAll(IEnumerable<Task>)
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Numaralandırılabilir bir koleksiyondaki Task tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur.
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 TaskParametreler
- tasks
- IEnumerable<Task>
Tamamlanmasını beklemeniz gereken görevler.
Döndürülenler
Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.
Özel durumlar
Bağımsız tasks değişken: null.
Koleksiyon tasks bir null görev içeriyor.
Örnekler
Aşağıdaki örnek, dizideki URL'lere ping atan bir görev kümesi oluşturur. Görevler yöntemine geçirilen bir List<Task> koleksiyonda WhenAll(IEnumerable<Task>) depolanır. yöntemine yapılan çağrı tüm iş parçacıklarının Wait tamamlandığından emin olduktan sonra, örnek özelliği inceleyerek Task.Status herhangi bir görevde hata olup olmadığını belirler.
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
Açıklamalar
Bir nesne döndüren yöntemin WhenAll aşırı yüklemeleri genellikle bir Task görev kümesinin durumuyla veya bir görev kümesi tarafından oluşan özel durumlarla ilgilendiğinizde çağrılır.
Not
yöntemi çağrısı WhenAll(IEnumerable<Task>) , çağıran iş parçacığını engellemez.
Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de bir Faulted durumda tamamlanır ve burada özel durumları sağlanan görevlerin her birinden eşlenmemiş özel durumlar kümesinin toplanmasını içerir.
Sağlanan görevlerden hiçbiri hatalı değilse ancak bunlardan en az biri iptal edildiyse, döndürülen görev durumunda sona erer Canceled .
Görevlerden hiçbiri hatalı değilse ve görevlerden hiçbiri iptal edilmediyse, sonuçta elde edilen görev durumunda sona erer RanToCompletion .
Sağlanan dizi/numaralandırılabilir görev içermiyorsa, döndürülen görev çağırana döndürülmeden hemen bir RanToCompletion duruma geçer.
Şunlara uygulanır
WhenAll(Task[])
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Bir dizideki Task tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur.
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 TaskParametreler
- tasks
- Task[]
Tamamlanmasını beklemeniz gereken görevler.
Döndürülenler
Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.
Özel durumlar
Bağımsız tasks değişken: null.
Dizi tasks bir null görev içeriyor.
Örnekler
Aşağıdaki örnek, dizideki URL'lere ping atan bir görev kümesi oluşturur. Görevler, diziye List<Task> dönüştürülen ve yöntemine geçirilen bir koleksiyonda WhenAll(IEnumerable<Task>) depolanır. yöntemine yapılan çağrı tüm iş parçacıklarının Wait tamamlandığından emin olduktan sonra, örnek özelliği inceleyerek Task.Status herhangi bir görevde hata olup olmadığını belirler.
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
Açıklamalar
Bir nesne döndüren yöntemin WhenAll aşırı yüklemeleri genellikle bir Task görev kümesinin durumuyla veya bir görev kümesi tarafından oluşan özel durumlarla ilgilendiğinizde çağrılır.
Not
yöntemi çağrısı WhenAll(Task[]) , çağıran iş parçacığını engellemez.
Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de bir Faulted durumda tamamlanır ve burada özel durumları sağlanan görevlerin her birinden eşlenmemiş özel durumlar kümesinin toplanmasını içerir.
Sağlanan görevlerden hiçbiri hatalı değilse ancak bunlardan en az biri iptal edildiyse, döndürülen görev durumunda sona erer Canceled .
Görevlerden hiçbiri hatalı değilse ve görevlerden hiçbiri iptal edilmediyse, sonuçta elde edilen görev durumunda sona erer RanToCompletion .
Sağlanan dizi/numaralandırılabilir görev içermiyorsa, döndürülen görev çağırana döndürülmeden hemen bir RanToCompletion duruma geçer.
Şunlara uygulanır
WhenAll<TResult>(IEnumerable<Task<TResult>>)
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Numaralandırılabilir bir koleksiyondaki Task<TResult> tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur.
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())Tür Parametreleri
- TResult
Tamamlanan görevin türü.
Parametreler
- tasks
- IEnumerable<Task<TResult>>
Tamamlanmasını beklemeniz gereken görevler.
Döndürülenler
Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.
Özel durumlar
Bağımsız tasks değişken: null.
Koleksiyon tasks bir null görev içeriyor.
Örnekler
Aşağıdaki örnek, her biri 1 ile 1.000 arasında rastgele 1.000 sayı oluşturan ve ortalamalarını hesaplayan rastgele bir sayı oluşturucu oluşturan on görev oluşturur. yöntemi, Delay(Int32) rastgele sayı oluşturucuların aynı tohum değerleriyle oluşturulmaması için örneklemeyi geciktirmek için kullanılır. Yöntemine yapılan WhenAll çağrı daha sonra her görev tarafından hesaplanan ortalamayı içeren bir Int64 dizi döndürür. Bunlar daha sonra genel ortalamayı hesaplamak için kullanılır.
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
Bu durumda, on ayrı görev bir List<T> nesnede depolanır. List<T> arabirimini IEnumerable<T> uygular.
Açıklamalar
yöntemi çağrısı WhenAll<TResult>(IEnumerable<Task<TResult>>) , çağıran iş parçacığını engellemez. Ancak, döndürülen Result özelliğine yapılan bir çağrı, çağıran iş parçacığını engeller.
Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de bir Faulted durumda tamamlanır ve burada özel durumları sağlanan görevlerin her birinden eşlenmemiş özel durumlar kümesinin toplanmasını içerir.
Sağlanan görevlerden hiçbiri hatalı değilse ancak bunlardan en az biri iptal edildiyse, döndürülen görev durumunda sona erer Canceled .
Görevlerden hiçbiri hatalı değilse ve görevlerden hiçbiri iptal edilmediyse, sonuçta elde edilen görev durumunda sona erer RanToCompletion . Task<TResult>.Result Döndürülen görevin özelliği, sağlanan görevlerin tüm sonuçlarını sağlanan sırayla içeren bir diziye ayarlanır (örneğin, giriş görevleri dizisi t1, t2, t3 içeriyorsa, çıkış görevinin Task<TResult>.Result özelliği bir TResult[] where arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)döndürür.
tasks Bağımsız değişken görev içermiyorsa, döndürülen görev çağırana döndürülmeden hemen bir RanToCompletion duruma geçer. Döndürülen TResult[] , 0 öğeden oluşan bir dizi olacaktır.
Şunlara uygulanır
WhenAll<TResult>(Task<TResult>[])
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Bir dizideki Task<TResult> tüm nesneler tamamlandığında tamamlanacak bir görev oluşturur.
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())Tür Parametreleri
- TResult
Tamamlanan görevin türü.
Parametreler
- tasks
- Task<TResult>[]
Tamamlanmasını beklemeniz gereken görevler.
Döndürülenler
Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.
Özel durumlar
Bağımsız tasks değişken: null.
Dizi tasks bir null görev içeriyor.
Örnekler
Aşağıdaki örnek, her biri 1 ile 1.000 arasında rastgele 1.000 sayı oluşturan ve ortalamalarını hesaplayan rastgele bir sayı oluşturucu oluşturan on görev oluşturur. Bu durumda, on tek tek görev bir Task<Int64> dizide depolanır. yöntemi, Delay(Int32) rastgele sayı oluşturucuların aynı tohum değerleriyle oluşturulmaması için örneklemeyi geciktirmek için kullanılır. Yöntemine yapılan WhenAll çağrı daha sonra her görev tarafından hesaplanan ortalamayı içeren bir Int64 dizi döndürür. Bunlar daha sonra genel ortalamayı hesaplamak için kullanılır.
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
Açıklamalar
yöntemi çağrısı WhenAll<TResult>(Task<TResult>[]) , çağıran iş parçacığını engellemez. Ancak, döndürülen Result özelliğine yapılan bir çağrı, çağıran iş parçacığını engeller.
Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de bir Faulted durumda tamamlanır ve burada özel durumları sağlanan görevlerin her birinden eşlenmemiş özel durumlar kümesinin toplanmasını içerir.
Sağlanan görevlerden hiçbiri hatalı değilse ancak bunlardan en az biri iptal edildiyse, döndürülen görev durumunda sona erer Canceled .
Görevlerden hiçbiri hatalı değilse ve görevlerden hiçbiri iptal edilmediyse, sonuçta elde edilen görev durumunda sona erer RanToCompletion . Result Döndürülen görevin değeri, sağlanan görevlerin tüm sonuçlarını sağlanan sırayla içeren bir diziye ayarlanır (örneğin, giriş görevleri dizisi t1, t2, t3 içeriyorsa, çıkış görevleri Result bir TResult[] where arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)döndürür.
Sağlanan dizi/numaralandırılabilir görev içermiyorsa, döndürülen görev çağırana döndürülmeden hemen bir RanToCompletion duruma geçer. Döndürülen TResult[] , 0 öğeden oluşan bir dizi olacaktır.
Şunlara uygulanır
Geri Bildirim
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz. https://aka.ms/ContentUserFeedback.
Gönderin ve geri bildirimi görüntüleyin