Task.WhenAll Yöntem

Tanım

Ad Alanı:

System.Threading.Tasks

Bütünleştirilmiş Kod:

System.Runtime.dll

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 tüm Task nesneleri tamamlandığında tamamlanacak bir görev oluşturur.
WhenAll(Task[])	Dizideki tüm Task nesneleri tamamlandığında tamamlanacak bir görev oluşturur.
WhenAll<TResult>(IEnumerable<Task<TResult>>)	Numaralandırılabilir bir koleksiyondaki tüm Task<TResult> nesneleri tamamlandığında tamamlanacak bir görev oluşturur.
WhenAll<TResult>(Task<TResult>[])	Dizideki tüm Task<TResult> nesneleri tamamlandığında tamamlanacak bir görev oluşturur.

WhenAll(IEnumerable<Task>)

Kaynak:

Task.cs

Numaralandırılabilir bir koleksiyondaki tüm Task nesneleri tamamlandığında tamamlanacak bir görev oluşturur.

C#

public static System.Threading.Tasks.Task WhenAll (System.Collections.Generic.IEnumerable<System.Threading.Tasks.Task> tasks);

Parametreler

tasks

IEnumerable<Task>

Tamamlanmasını beklemeniz gereken görevler.

Döndürülenler

Task

Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.

Özel durumlar

ArgumentNullException

tasks bağımsız değişkeni null.

ArgumentException

tasks koleksiyonu bir null görevi içeriyordu.

Örnekler

Aşağıdaki örnek, dizideki URL'lere ping atan bir görev kümesi oluşturur. Görevler, WhenAll(IEnumerable<Task>) yöntemine geçirilen bir List<Task> koleksiyonunda depolanır. Wait yöntemine yapılan çağrı tüm iş parçacıklarının tamamlanmasını sağladıktan sonra, örnek Task.Status özelliğini inceleyerek herhangi bir görevde hata olup olmadığını belirler.

C#

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

Açıklamalar

bir Task nesnesi döndüren WhenAll yönteminin aşırı yüklemeleri genellikle bir görev kümesinin durumuyla veya bir görev kümesi tarafından oluşan özel durumlarla ilgilendiğinizde çağrılır.

Not

WhenAll(IEnumerable<Task>) yöntemi çağrısı, çağıran iş parçacığını engellemez.

Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de Faulted durumunda 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 Canceled durumunda sona erer.

Görevlerin hiçbiri hatalı değilse ve hiçbir görev iptal edilmediyse, sonuçta elde edilen görev RanToCompletion durumunda sona erer.

Sağlanan dizi/numaralandırılabilir görev içermiyorsa, döndürülen görev çağırana döndürülmeden önce hemen RanToCompletion durumuna geçer.

WhenAll(Task[])

Kaynak:

Task.cs

Dizideki tüm Task nesneleri tamamlandığında tamamlanacak bir görev oluşturur.

C#

public static System.Threading.Tasks.Task WhenAll (params System.Threading.Tasks.Task[] tasks);

Parametreler

tasks

Task[]

Tamamlanmasını beklemeniz gereken görevler.

Döndürülenler

Task

Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.

Özel durumlar

ArgumentNullException

tasks bağımsız değişkeni null.

ArgumentException

tasks dizisi bir null görevi içeriyordu.

Örnekler

Aşağıdaki örnek, dizideki URL'lere ping atan bir görev kümesi oluşturur. Görevler, diziye dönüştürülen ve WhenAll(IEnumerable<Task>) yöntemine geçirilen bir List<Task> koleksiyonunda depolanır. Wait yöntemine yapılan çağrı tüm iş parçacıklarının tamamlanmasını sağladıktan sonra, örnek Task.Status özelliğini inceleyerek herhangi bir görevde hata olup olmadığını belirler.

C#

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

Açıklamalar

bir Task nesnesi döndüren WhenAll yönteminin aşırı yüklemeleri genellikle bir görev kümesinin durumuyla veya bir görev kümesi tarafından oluşan özel durumlarla ilgilendiğinizde çağrılır.

Not

WhenAll(Task[]) yöntemi çağrısı, çağıran iş parçacığını engellemez.

Sağlanan görevlerden herhangi biri hatalı durumda tamamlanırsa, döndürülen görev de Faulted durumunda 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 Canceled durumunda sona erer.

Görevlerin hiçbiri hatalı değilse ve hiçbir görev iptal edilmediyse, sonuçta elde edilen görev RanToCompletion durumunda sona erer.

Sağlanan dizi/numaralandırılabilir görev içermiyorsa, döndürülen görev çağırana döndürülmeden önce hemen RanToCompletion durumuna geçer.

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

Kaynak:

Task.cs

Numaralandırılabilir bir koleksiyondaki tüm Task<TResult> nesneleri tamamlandığında tamamlanacak bir görev oluşturur.

C#

public static System.Threading.Tasks.Task<TResult[]> WhenAll<TResult> (System.Collections.Generic.IEnumerable<System.Threading.Tasks.Task<TResult>> tasks);

Tür Parametreleri

TResult

Tamamlanan görevin türü.

Parametreler

tasks

IEnumerable<Task<TResult>>

Tamamlanmasını beklemeniz gereken görevler.

Döndürülenler

Task<TResult[]>

Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.

Özel durumlar

ArgumentNullException

tasks bağımsız değişkeni null.

ArgumentException

tasks koleksiyonu bir null görevi içeriyordu.

Örnekler

Aşağıdaki örnek, her biri 1 ile 1.000 arasında rastgele 1000 sayı oluşturan ve ortalamasını hesaplayan rastgele bir sayı oluşturucu oluşturan on görev oluşturur. Delay(Int32) yöntemi, aynı tohum değerleriyle oluşturulmamaları için rastgele sayı oluşturucuların örneklemesini geciktirmek için kullanılır. daha sonra WhenAll yöntemine yapılan çağrı, her görev tarafından hesaplanan ortalamayı içeren bir Int64 dizisi döndürür. Bunlar daha sonra genel ortalamayı hesaplamak için kullanılır.

C#

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

Bu durumda, on ayrı görev bir List<T> nesnesinde depolanır. List<T> IEnumerable<T> arabirimini uygular.

Açıklamalar

WhenAll<TResult>(IEnumerable<Task<TResult>>) yöntemi çağrısı, ç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 Faulted durumunda 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 Canceled durumunda sona erer.

Görevlerin hiçbiri hatalı değilse ve hiçbir görev iptal edilmediyse, sonuçta elde edilen görev RanToCompletion durumunda sona erer. Döndürülen görevin Task<TResult>.Result özelliği, sağlanan görevlerin tüm sonuçlarını sağlandığı sırada 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 arr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)bir TResult[] döndürür.

tasks bağımsız değişkeni görev içermiyorsa, döndürülen görev çağırana döndürülmeden önce hemen bir RanToCompletion durumuna geçer. Döndürülen TResult[] 0 öğeden oluşan bir dizi olacaktır.

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

Kaynak:

Task.cs

Dizideki tüm Task<TResult> nesneleri tamamlandığında tamamlanacak bir görev oluşturur.

C#

public static System.Threading.Tasks.Task<TResult[]> WhenAll<TResult> (params System.Threading.Tasks.Task<TResult>[] tasks);

Tür Parametreleri

TResult

Tamamlanan görevin türü.

Parametreler

tasks

Task<TResult>[]

Tamamlanmasını beklemeniz gereken görevler.

Döndürülenler

Task<TResult[]>

Sağlanan tüm görevlerin tamamlanmasını temsil eden görev.

Özel durumlar

ArgumentNullException

tasks bağımsız değişkeni null.

ArgumentException

tasks dizisi bir null görevi içeriyordu.

Örnekler

Aşağıdaki örnek, her biri 1 ile 1.000 arasında rastgele 1000 sayı oluşturan ve ortalamasını hesaplayan rastgele bir sayı oluşturucu oluşturan on görev oluşturur. Bu durumda, on ayrı görev bir Task<Int64> dizisinde depolanır. Delay(Int32) yöntemi, aynı tohum değerleriyle oluşturulmamaları için rastgele sayı oluşturucuların örneklemesini geciktirmek için kullanılır. daha sonra WhenAll yöntemine yapılan çağrı, her görev tarafından hesaplanan ortalamayı içeren bir Int64 dizisi döndürür. Bunlar daha sonra genel ortalamayı hesaplamak için kullanılır.

C#

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

Açıklamalar

WhenAll<TResult>(Task<TResult>[]) yöntemi çağrısı, ç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 Faulted durumunda 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 Canceled durumunda sona erer.

Görevlerin hiçbiri hatalı değilse ve hiçbir görev iptal edilmediyse, sonuçta elde edilen görev RanToCompletion durumunda sona erer. Döndürülen görevin Result, sağlanan görevlerin tüm sonuçlarını sağlandığı sırada içeren bir diziye ayarlanır (örneğin, giriş görevleri dizisi t1, t2, t3 içeriyorsa, çıkış görevinin Resultarr[0] == t1.Result, arr[1] == t2.Result, and arr[2] == t3.Result)bir TResult[] 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 önce hemen RanToCompletion durumuna geçer. Döndürülen TResult[] 0 öğeden oluşan bir dizi olacaktır.