Task.WhenAll 메서드

참조

정의

네임스페이스:: System.Threading.Tasks

어셈블리:: System.Threading.Tasks.dll

어셈블리:: System.Runtime.dll

어셈블리:: mscorlib.dll

어셈블리:: netstandard.dll

중요

일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.

제공된 작업을 모두 완료했을 때 완료할 작업을 만듭니다.

오버로드

WhenAll(IEnumerable<Task>)	열거 가능한 컬렉션의 모든 Task 개체가 완료되면 완료될 작업을 만듭니다.
WhenAll(Task[])	배열의 모든 Task 개체가 완료되면 완료될 작업을 만듭니다.
WhenAll<TResult>(IEnumerable<Task<TResult>>)	열거 가능한 컬렉션의 모든 Task<TResult> 개체가 완료되면 완료될 작업을 만듭니다.
WhenAll<TResult>(Task<TResult>[])	배열의 모든 Task<TResult> 개체가 완료되면 완료될 작업을 만듭니다.

WhenAll(IEnumerable<Task>)

열거 가능한 컬렉션의 모든 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.Task

Public Shared Function WhenAll (tasks As IEnumerable(Of Task)) As Task

매개 변수

tasks: IEnumerable<Task>

완료를 기다리는 작업입니다.

반환

Task

제공된 모든 작업의 완료를 나타내는 작업입니다.

예외

ArgumentNullException

tasks 인수가 null인 경우

ArgumentException

null 작업이 포함된 tasks 컬렉션입니다.

예제

다음 예제에서는 배열에서 URL을 ping하는 작업 집합을 만듭니다. 작업은 메서드에 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

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 하는 메서드의 오버로드는 일반적으로 작업 집합의 상태 또는 태스크 집합에서 throw된 예외에 관심이 있을 때 호출됩니다.

참고

메서드 호출 WhenAll(IEnumerable<Task>) 은 호출 스레드를 차단하지 않습니다.

제공된 작업 중 오류가 발생한 상태에서 완료된 경우 반환된 태스크도 상태에서 완료 Faulted 됩니다. 여기서 해당 예외에는 제공된 각 태스크에서 래핑되지 않은 예외 집합의 집계가 포함됩니다.

제공된 작업 중 오류가 없지만 하나 이상의 작업이 취소된 경우 반환된 작업은 상태가 종료 Canceled 됩니다.

오류가 발생한 태스크가 없으며 취소된 작업이 없는 경우 결과 작업은 상태로 종료 RanToCompletion 됩니다.

제공된 배열/열거형에 태스크가 없는 경우 반환된 태스크는 호출자에게 반환되기 전에 즉시 상태로 전환 RanToCompletion 됩니다.

적용 대상

WhenAll(Task[])

배열의 모든 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.Task

Public Shared Function WhenAll (ParamArray tasks As Task()) As Task

매개 변수

tasks: Task[]

완료를 기다리는 작업입니다.

반환

Task

제공된 모든 작업의 완료를 나타내는 작업입니다.

예외

ArgumentNullException

tasks 인수가 null인 경우

ArgumentException

null 작업이 포함된 tasks 배열입니다.

예제

다음 예제에서는 배열에서 URL을 ping하는 작업 집합을 만듭니다. 작업은 배열로 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

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 하는 메서드의 오버로드는 일반적으로 작업 집합의 상태 또는 태스크 집합에서 throw된 예외에 관심이 있을 때 호출됩니다.

참고

메서드 호출 WhenAll(Task[]) 은 호출 스레드를 차단하지 않습니다.

제공된 작업 중 오류가 없지만 하나 이상의 작업이 취소된 경우 반환된 작업은 상태가 종료 Canceled 됩니다.

오류가 발생한 태스크가 없으며 취소된 작업이 없는 경우 결과 작업은 상태로 종료 RanToCompletion 됩니다.

제공된 배열/열거형에 태스크가 없는 경우 반환된 태스크는 호출자에게 반환되기 전에 즉시 상태로 전환 RanToCompletion 됩니다.

적용 대상

WhenAll<TResult>(IEnumerable<Task<TResult>>)

열거 가능한 컬렉션의 모든 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>>

완료를 기다리는 작업입니다.

반환

Task<TResult[]>

제공된 모든 작업의 완료를 나타내는 작업입니다.

예외

ArgumentNullException

tasks 인수가 null인 경우

ArgumentException

null 작업이 포함된 tasks 컬렉션입니다.

예제

다음 예제에서는 각각 1에서 1,000 사이의 난수 1,000개를 만들고 평균을 계산하는 난수 생성기를 인스턴스화하는 10개의 작업을 만듭니다. 이 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

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

이 경우 10개의 개별 작업이 개체에 List<T> 저장됩니다. List<T>는 IEnumerable<T> 인터페이스를 구현합니다.

설명

메서드 호출 WhenAll<TResult>(IEnumerable<Task<TResult>>) 은 호출 스레드를 차단하지 않습니다. 그러나 반환 Result 된 속성에 대한 호출은 호출 스레드를 차단합니다.

제공된 작업 중 오류가 없지만 하나 이상의 작업이 취소된 경우 반환된 작업은 상태가 종료 Canceled 됩니다.

오류가 발생한 태스크가 없으며 취소된 작업이 없는 경우 결과 작업은 상태로 종료 RanToCompletion 됩니다. 반환된 태스크의 속성은 Task<TResult>.Result 제공된 것과 동일한 순서로 제공된 작업의 모든 결과를 포함하는 배열로 설정됩니다(예: 입력 작업 배열에 t1, t2, t3이 포함된 경우 출력 태스크의 Task<TResult>.Result 속성은 위치를 arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)반환 TResult[] 합니다.

인수에 tasks 태스크가 없는 경우 반환된 태스크는 호출자에게 반환되기 전에 즉시 상태로 전환 RanToCompletion 됩니다. 반환 TResult[] 된 항목은 0 요소의 배열입니다.

적용 대상

WhenAll<TResult>(Task<TResult>[])

배열의 모든 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>[]

완료를 기다리는 작업입니다.

반환

Task<TResult[]>

제공된 모든 작업의 완료를 나타내는 작업입니다.

예외

ArgumentNullException

tasks 인수가 null인 경우

ArgumentException

null 작업이 포함된 tasks 배열입니다.

예제

다음 예제에서는 각각 1에서 1,000 사이의 난수 1,000개를 만들고 평균을 계산하는 난수 생성기를 인스턴스화하는 10개의 작업을 만듭니다. 이 경우 10개의 개별 작업이 배열에 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

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 된 속성에 대한 호출은 호출 스레드를 차단합니다.

제공된 작업 중 오류가 없지만 하나 이상의 작업이 취소된 경우 반환된 작업은 상태가 종료 Canceled 됩니다.

오류가 발생한 태스크가 없으며 취소된 작업이 없는 경우 결과 작업은 상태로 종료 RanToCompletion 됩니다. 반환된 태스크는 Result 제공된 것과 동일한 순서로 제공된 작업의 모든 결과를 포함하는 배열로 설정됩니다(예: 입력 작업 배열에 t1, t2, t3이 포함된 경우 출력 태스크는 Result 위치를 arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)반환 TResult[] 합니다.

제공된 배열/열거형에 태스크가 없는 경우 반환된 태스크는 호출자에게 반환되기 전에 즉시 상태로 전환 RanToCompletion 됩니다. 반환 TResult[] 된 항목은 0 요소의 배열입니다.

적용 대상

다음을 통해 공유

Task.WhenAll 메서드

정의

오버로드

WhenAll(IEnumerable<Task>)

매개 변수

반환

예외

예제

설명

적용 대상

WhenAll(Task[])

매개 변수

반환

예외

예제

설명

적용 대상

WhenAll<TResult>(IEnumerable<Task<TResult>>)

형식 매개 변수

매개 변수

반환

예외

예제

설명

적용 대상

WhenAll<TResult>(Task<TResult>[])

형식 매개 변수

매개 변수

반환

예외

예제

설명

적용 대상

추가 리소스