TaskFactory<TResult> Класс

Определение

generic <typename TResult>
public ref class TaskFactory

public class TaskFactory<TResult>

type TaskFactory<'Result> = class

Public Class TaskFactory(Of TResult)

Параметры типа

Наследование

Object

TaskFactory<TResult>

Примеры

В следующем примере используется статическое Factory свойство для выполнения двух вызовов TaskFactory<TResult>.StartNew метода . Первая задача возвращает массив строк, заполненный именами файлов в каталоге MyDocuments пользователя, а вторая — массив строк, заполненный именами подкаталогов каталога MyDocuments пользователя. Затем он вызывает TaskFactory.ContinueWhenAll(Task[], Action<Task[]>) метод , который отображает сведения о количестве файлов и каталогов в массивах, возвращаемых двумя задачами после их выполнения.

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

Комментарии

.NET предоставляет две фабрики для создания и планирования задач:

• Класс TaskFactory , который создает Task объекты и Task<TResult> .

• Класс TaskFactory<TResult> , который создает Task<TResult> объекты.

Класс TaskFactory<TResult> позволяет выполнять следующие действия:

• Создайте задачу и немедленно запустите ее, вызвав StartNew метод . Вы можете вызвать перегрузки этого метода, чтобы создать и выполнить задачу, требующую аргументов, отличных от аргументов по умолчанию.

  Предупреждение

  Начиная с платформа .NET Framework 4.5, Task.Run метод предоставляет самый простой способ создать задачу со значениями конфигурации по умолчанию и немедленно запустить ее.

• Создайте задачу, которая запускается после завершения любой из задач в массиве путем вызова ContinueWhenAny метода или ContinueWhenAny .

• Создайте задачу, которая запускается после завершения всех задач в массиве, вызвав ContinueWhenAll метод или ContinueWhenAll .

Статическое Task<TResult>.Factory свойство возвращает объект по умолчанию TaskFactory<TResult> . Можно также вызвать один из TaskFactory<TResult> конструкторов класса для настройки Task<TResult> объектов, создаваемых классом TaskFactory<TResult> . В следующем примере настраивается новый TaskFactory<TResult> объект для создания задач с указанным маркером отмены, параметрами создания задач, параметрами продолжения и настроенным планировщиком задач.

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

В большинстве случаев не требуется создавать экземпляр нового TaskFactory<TResult> экземпляра. Вместо этого можно использовать статическое Task<TResult>.Factory свойство , которое возвращает объект фабрики, использующий значения по умолчанию. Затем можно вызвать его методы для запуска новых задач или определения продолжений задач. Пример см. в этом примере.

Конструкторы

Свойства

Методы

Применяется к

Потокобезопасность

Все общедоступные и защищенные члены TaskFactory<TResult> являются потокобезопасными и могут использоваться одновременно из нескольких потоков.

См. также раздел

• Библиотека параллельных задач (TPL)