Task.WhenAll Metode
Definisi
Penting
Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.
Membuat tugas yang akan selesai ketika semua tugas yang disediakan telah selesai.
Overload
| WhenAll(IEnumerable<Task>) |
Membuat tugas yang akan selesai ketika semua Task objek dalam koleksi yang dapat dijumlahkan telah selesai. |
| WhenAll(Task[]) |
Membuat tugas yang akan selesai ketika semua Task objek dalam array telah selesai. |
| WhenAll<TResult>(IEnumerable<Task<TResult>>) |
Membuat tugas yang akan selesai ketika semua Task<TResult> objek dalam koleksi yang dapat dijumlahkan telah selesai. |
| WhenAll<TResult>(Task<TResult>[]) |
Membuat tugas yang akan selesai ketika semua Task<TResult> objek dalam array telah selesai. |
WhenAll(IEnumerable<Task>)
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Membuat tugas yang akan selesai ketika semua Task objek dalam koleksi yang dapat dijumlahkan telah selesai.
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 TaskParameter
- tasks
- IEnumerable<Task>
Tugas yang harus ditunggu selesai.
Mengembalikan
Tugas yang mewakili penyelesaian semua tugas yang disediakan.
Pengecualian
Argumennya tasks adalah null.
Koleksi tasks berisi null tugas.
Contoh
Contoh berikut membuat sekumpulan tugas yang melakukan ping URL dalam array. Tugas disimpan dalam List<Task> koleksi yang diteruskan ke WhenAll(IEnumerable<Task>) metode . Setelah panggilan ke Wait metode memastikan bahwa semua utas telah selesai, contohnya memeriksa Task.Status properti untuk menentukan apakah ada tugas yang salah.
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
Keterangan
Kelebihan beban WhenAll metode yang mengembalikan Task objek biasanya dipanggil ketika Anda tertarik dengan status sekumpulan tugas atau dalam pengecualian yang dilemparkan oleh serangkaian tugas.
Catatan
Panggilan ke WhenAll(IEnumerable<Task>) metode tidak memblokir utas panggilan.
Jika salah satu tugas yang disediakan selesai dalam keadaan rusak, tugas yang dikembalikan juga akan selesai dalam keadaan Faulted , di mana pengecualiannya akan berisi agregasi kumpulan pengecualian yang tidak dibungkus dari setiap tugas yang disediakan.
Jika tidak ada tugas yang diberikan yang rusak tetapi setidaknya salah satu dari mereka dibatalkan, tugas yang dikembalikan akan berakhir dalam status Canceled .
Jika tidak ada tugas yang rusak dan tidak ada tugas yang dibatalkan, tugas yang dihasilkan akan berakhir dalam status RanToCompletion .
Jika array yang disediakan/enumerable tidak berisi tugas, tugas yang dikembalikan akan segera beralih ke status RanToCompletion sebelum dikembalikan ke pemanggil.
Berlaku untuk
WhenAll(Task[])
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Membuat tugas yang akan selesai ketika semua Task objek dalam array telah selesai.
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 TaskParameter
- tasks
- Task[]
Tugas yang harus ditunggu selesai.
Mengembalikan
Tugas yang mewakili penyelesaian semua tugas yang disediakan.
Pengecualian
Argumennya tasks adalah null.
Array tasks berisi null tugas.
Contoh
Contoh berikut membuat sekumpulan tugas yang melakukan ping URL dalam array. Tugas disimpan dalam List<Task> koleksi yang dikonversi ke array dan diteruskan ke WhenAll(IEnumerable<Task>) metode . Setelah panggilan ke Wait metode memastikan bahwa semua utas telah selesai, contohnya memeriksa Task.Status properti untuk menentukan apakah ada tugas yang salah.
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
Keterangan
Kelebihan beban WhenAll metode yang mengembalikan Task objek biasanya dipanggil ketika Anda tertarik dengan status sekumpulan tugas atau dalam pengecualian yang dilemparkan oleh serangkaian tugas.
Catatan
Panggilan ke WhenAll(Task[]) metode tidak memblokir utas panggilan.
Jika salah satu tugas yang disediakan selesai dalam keadaan rusak, tugas yang dikembalikan juga akan selesai dalam keadaan Faulted , di mana pengecualiannya akan berisi agregasi kumpulan pengecualian yang tidak dibungkus dari setiap tugas yang disediakan.
Jika tidak ada tugas yang diberikan yang rusak tetapi setidaknya salah satu dari mereka dibatalkan, tugas yang dikembalikan akan berakhir dalam status Canceled .
Jika tidak ada tugas yang rusak dan tidak ada tugas yang dibatalkan, tugas yang dihasilkan akan berakhir dalam status RanToCompletion .
Jika array yang disediakan/enumerable tidak berisi tugas, tugas yang dikembalikan akan segera beralih ke status RanToCompletion sebelum dikembalikan ke pemanggil.
Berlaku untuk
WhenAll<TResult>(IEnumerable<Task<TResult>>)
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Membuat tugas yang akan selesai ketika semua Task<TResult> objek dalam koleksi yang dapat dijumlahkan telah selesai.
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())Jenis parameter
- TResult
Jenis tugas yang telah selesai.
Parameter
- tasks
- IEnumerable<Task<TResult>>
Tugas yang harus ditunggu selesai.
Mengembalikan
Tugas yang mewakili penyelesaian semua tugas yang disediakan.
Pengecualian
Argumennya tasks adalah null.
Koleksi tasks berisi null tugas.
Contoh
Contoh berikut membuat sepuluh tugas, yang masing-masing membuat generator angka acak yang membuat 1.000 angka acak antara 1 dan 1.000 dan menghitung rata-ratanya. Metode Delay(Int32) ini digunakan untuk menunda instansiasi generator angka acak sehingga tidak dibuat dengan nilai benih yang identik. Panggilan ke WhenAll metode kemudian mengembalikan Int64 array yang berisi rata-rata yang dihitung oleh setiap tugas. Ini kemudian digunakan untuk menghitung rata-rata keseluruhan.
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
Dalam hal ini, sepuluh tugas individual disimpan dalam objek List<T> . List<T> mengimplementasikan antarmuka IEnumerable<T>.
Keterangan
Panggilan ke WhenAll<TResult>(IEnumerable<Task<TResult>>) metode tidak memblokir utas panggilan. Namun, panggilan ke properti yang dikembalikan Result memblokir utas panggilan.
Jika salah satu tugas yang disediakan selesai dalam keadaan rusak, tugas yang dikembalikan juga akan selesai dalam keadaan Faulted , di mana pengecualiannya akan berisi agregasi kumpulan pengecualian yang tidak dibungkus dari setiap tugas yang disediakan.
Jika tidak ada tugas yang diberikan yang rusak tetapi setidaknya salah satu dari mereka dibatalkan, tugas yang dikembalikan akan berakhir dalam status Canceled .
Jika tidak ada tugas yang rusak dan tidak ada tugas yang dibatalkan, tugas yang dihasilkan akan berakhir dalam status RanToCompletion . Task<TResult>.Result Properti tugas yang dikembalikan akan diatur ke array yang berisi semua hasil tugas yang disediakan dalam urutan yang sama seperti yang disediakan (misalnya jika array tugas input berisi t1, t2, t3, properti tugas Task<TResult>.Result output akan mengembalikan TResult[] di mana arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
tasks Jika argumen tidak berisi tugas, tugas yang dikembalikan akan segera beralih ke status RanToCompletion sebelum dikembalikan ke pemanggil. Yang dikembalikan TResult[] akan menjadi array 0 elemen.
Berlaku untuk
WhenAll<TResult>(Task<TResult>[])
- Source:
- Task.cs
- Source:
- Task.cs
- Source:
- Task.cs
Membuat tugas yang akan selesai ketika semua Task<TResult> objek dalam array telah selesai.
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())Jenis parameter
- TResult
Jenis tugas yang telah selesai.
Parameter
- tasks
- Task<TResult>[]
Tugas yang harus ditunggu selesai.
Mengembalikan
Tugas yang mewakili penyelesaian semua tugas yang disediakan.
Pengecualian
Argumennya tasks adalah null.
Array tasks berisi null tugas.
Contoh
Contoh berikut membuat sepuluh tugas, yang masing-masing membuat generator angka acak yang membuat 1.000 angka acak antara 1 dan 1.000 dan menghitung rata-ratanya. Dalam hal ini, sepuluh tugas individual disimpan dalam Task<Int64> array. Metode Delay(Int32) ini digunakan untuk menunda instansiasi generator angka acak sehingga tidak dibuat dengan nilai benih yang identik. Panggilan ke WhenAll metode kemudian mengembalikan Int64 array yang berisi rata-rata yang dihitung oleh setiap tugas. Ini kemudian digunakan untuk menghitung rata-rata keseluruhan.
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
Keterangan
Panggilan ke WhenAll<TResult>(Task<TResult>[]) metode tidak memblokir utas panggilan. Namun, panggilan ke properti yang dikembalikan Result memblokir utas panggilan.
Jika salah satu tugas yang disediakan selesai dalam keadaan rusak, tugas yang dikembalikan juga akan selesai dalam keadaan Faulted , di mana pengecualiannya akan berisi agregasi kumpulan pengecualian yang tidak dibungkus dari setiap tugas yang disediakan.
Jika tidak ada tugas yang diberikan yang rusak tetapi setidaknya salah satu dari mereka dibatalkan, tugas yang dikembalikan akan berakhir dalam status Canceled .
Jika tidak ada tugas yang rusak dan tidak ada tugas yang dibatalkan, tugas yang dihasilkan akan berakhir dalam status RanToCompletion . Tugas Result yang dikembalikan akan diatur ke array yang berisi semua hasil tugas yang disediakan dalam urutan yang sama seperti yang disediakan (misalnya jika array tugas input berisi t1, t2, t3, tugas Result output akan mengembalikan TResult[] di mana arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result).
Jika array yang disediakan/enumerable tidak berisi tugas, tugas yang dikembalikan akan segera beralih ke status RanToCompletion sebelum dikembalikan ke pemanggil. Yang dikembalikan TResult[] akan menjadi array 0 elemen.
Berlaku untuk
Saran dan Komentar
Segera hadir: Sepanjang tahun 2024 kami akan menghentikan penggunaan GitHub Issues sebagai mekanisme umpan balik untuk konten dan menggantinya dengan sistem umpan balik baru. Untuk mengetahui informasi selengkapnya, lihat: https://aka.ms/ContentUserFeedback.
Kirim dan lihat umpan balik untuk