TaskFactory<TResult> Sınıf

Tanım

generic <typename TResult>
public ref class TaskFactory

public class TaskFactory<TResult>

type TaskFactory<'Result> = class

Public Class TaskFactory(Of TResult)

Tür Parametreleri

Devralma

Object

TaskFactory<TResult>

Örnekler

Aşağıdaki örnek, yöntemine iki çağrı yapmak için TaskFactory<TResult>.StartNew statik Factory özelliğini kullanır. İlk görev, kullanıcının MyDocuments dizinindeki dosyaların adlarıyla doldurulmuş bir dize dizisi döndürürken, ikincisi kullanıcının MyDocuments dizininin alt dizinlerinin adlarıyla doldurulmuş bir dize dizisi döndürür. Ardından, yürütmeyi TaskFactory.ContinueWhenAll(Task[], Action<Task[]>) tamamladıktan sonra iki görev tarafından döndürülen dizilerdeki dosya ve dizin sayısı hakkında bilgi görüntüleyen yöntemini çağırır.

using System;
using System.IO;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      Task<string[]>[] tasks = new Task<string[]>[2];
      String docsDirectory = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments);

      tasks[0] = Task<string[]>.Factory.StartNew( () => Directory.GetFiles(docsDirectory));
      tasks[1] = Task<string[]>.Factory.StartNew( () => Directory.GetDirectories(docsDirectory));

      Task.Factory.ContinueWhenAll(tasks, completedTasks => {
                                             Console.WriteLine("{0} contains: ", docsDirectory);
                                             Console.WriteLine("   {0} subdirectories", tasks[1].Result.Length);
                                             Console.WriteLine("   {0} files", tasks[0].Result.Length);
                                          } );
   }
}
// The example displays output like the following:
//       C:\Users\<username>\Documents contains:
//          24 subdirectories
//          16 files

Imports System.IO
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim tasks(1) As Task(Of String())
      Dim docsDirectory As String = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments)
      
      tasks(0) = Task(Of String()).Factory.StartNew( Function()Directory.GetFiles(docsDirectory) )
''                                        End Sub )
      tasks(1) = Task(Of String()).Factory.StartNew( Function() Directory.GetDirectories(docsDirectory) )
''                                        End Sub )
      Task.Factory.ContinueWhenAll(tasks, Sub(completedTasks)
                                             Console.WriteLine("{0} contains: ", docsDirectory)
                                             Console.WriteLine("   {0} subdirectories", tasks(1).Result.Length)
                                             Console.WriteLine("   {0} files", tasks(0).Result.Length)
                                          End Sub)
   End Sub
End Module
' The example displays output like the following:
'       C:\Users\<username>\Documents contains:
'          24 subdirectories
'          16 files

Açıklamalar

.NET, görevleri oluşturmak ve zamanlamak için iki fabrika sağlar:

• TaskFactory ve Task<TResult> nesnelerini oluşturan Task sınıfı.

• TaskFactory<TResult> Nesneleri oluşturan Task<TResult> sınıfı.

TaskFactory<TResult> sınıfı aşağıdakileri yapmanıza olanak tanır:

• Bir görev oluşturun ve yöntemini çağırarak StartNew hemen başlatın. Varsayılan olmayan bağımsız değişkenler gerektiren bir görev oluşturmak ve yürütmek için bu yöntemin aşırı yüklemelerini çağırabilirsiniz.

  Uyarı

  .NET Framework 4.5'den başlayarak yöntemi, Task.Run varsayılan yapılandırma değerlerine sahip bir görev oluşturmanın ve hemen başlatmanın en kolay yolunu sağlar.

• Dizideki görevlerden herhangi biri tamamlandığında veya ContinueWhenAny yöntemini çağırarak ContinueWhenAny başlayan bir görev oluşturun.

• dizideki tüm görevler tamamlandığında veya ContinueWhenAll yöntemini çağırarak ContinueWhenAll başlayan bir görev oluşturun.

Statik Task<TResult>.Factory özellik varsayılan TaskFactory<TResult> bir nesne döndürür. Sınıfın TaskFactory<TResult> oluşturduğu nesneleri TaskFactory<TResult> yapılandırmak Task<TResult> için sınıf oluşturucularından birini de çağırabilirsiniz. Aşağıdaki örnek, belirtilen iptal belirtecine, görev oluşturma seçeneklerine, devam seçeneklerine ve özelleştirilmiş bir görev zamanlayıcıya sahip görevler oluşturmak için yeni TaskFactory<TResult> bir nesne yapılandırır.

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

public class Example
{
   static CancellationTokenSource cts = new CancellationTokenSource();

   static TaskFactory<int> factory = new TaskFactory<int>(
      cts.Token,
      TaskCreationOptions.PreferFairness,
      TaskContinuationOptions.ExecuteSynchronously,
      new CustomScheduler());

   static void Main()
   {
      var t2 = factory.StartNew(() => DoWork());
      cts.Dispose();
   }

   static int DoWork()
   {
       /*...*/
       return DateTime.Now.Hour <= 12 ?  1 : 2;
    }
}

Imports System.Collections.Generic
Imports System.Threading
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim cts As New CancellationTokenSource()
      Dim factory As New TaskFactory(Of Integer)(
                         cts.Token,
                         TaskCreationOptions.PreferFairness,
                         TaskContinuationOptions.ExecuteSynchronously,
                         New CustomScheduler())

      Dim t2 = factory.StartNew(Function() DoWork())
      cts.Dispose()
   End Sub

   Function DoWork() As Integer
      Return If(Date.Now.Hour <= 12, 1, 2)
   End Function
End Module

Çoğu durumda, yeni TaskFactory<TResult> bir örneğin örneğini oluşturmanız gerekmez. Bunun yerine, varsayılan değerleri kullanan bir fabrika nesnesi döndüren statik Task<TResult>.Factory özelliği kullanabilirsiniz. Ardından yeni görevleri başlatmak veya görev devamlılıklarını tanımlamak için yöntemlerini çağırabilirsiniz. Çizim için örne bakın.

Oluşturucular

Özellikler

Yöntemler

Şunlara uygulanır

İş Parçacığı Güvenliği

tüm genel ve korumalı üyeleri TaskFactory<TResult> iş parçacığı açısından güvenlidir ve birden çok iş parçacığından eşzamanlı olarak kullanılabilir.

Ayrıca bkz.

• Görev Paralel Kitaplığı (TPL)