Task.Run 메서드

참조

정의

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

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

어셈블리:: System.Runtime.dll

어셈블리:: mscorlib.dll

어셈블리:: netstandard.dll

중요

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

ThreadPool에서 실행할 지정된 작업을 큐에 대기하고 해당 작업에 대한 작업 또는 Task<TResult> 핸들을 반환합니다.

오버로드

Run(Func<Task>, CancellationToken)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 `function`반환된 작업에 대한 프록시를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.
Run(Action, CancellationToken)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task 개체를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.
Run(Func<Task>)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 `function`반환된 작업에 대한 프록시를 반환합니다.
Run(Action)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task 개체를 반환합니다.
Run<TResult>(Func<Task<TResult>>)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 `function`반환된 `Task(TResult)` 대한 프록시를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.
Run<TResult>(Func<TResult>)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task<TResult> 개체를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.
Run<TResult>(Func<Task<TResult>>, CancellationToken)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 `function`반환된 `Task(TResult)` 대한 프록시를 반환합니다.
Run<TResult>(Func<TResult>, CancellationToken)	스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 `Task(TResult)` 개체를 반환합니다.

설명

Run 메서드는 기본값을 사용하여 작업을 쉽게 시작할 수 있도록 하는 오버로드 집합을 제공합니다. StartNew 오버로드에 대한 간단한 대안입니다.

Run(Func<Task>, CancellationToken)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 function반환된 작업에 대한 프록시를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.

public:
 static System::Threading::Tasks::Task ^ Run(Func<System::Threading::Tasks::Task ^> ^ function, System::Threading::CancellationToken cancellationToken);

public static System.Threading.Tasks.Task Run (Func<System.Threading.Tasks.Task> function, System.Threading.CancellationToken cancellationToken);

public static System.Threading.Tasks.Task Run (Func<System.Threading.Tasks.Task?> function, System.Threading.CancellationToken cancellationToken);

static member Run : Func<System.Threading.Tasks.Task> * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Shared Function Run (function As Func(Of Task), cancellationToken As CancellationToken) As Task

매개 변수

function: Func<Task>

비동기적으로 실행할 작업입니다.

cancellationToken: CancellationToken

아직 시작하지 않은 경우 작업을 취소하는 데 사용할 수 있는 취소 토큰입니다. Run(Func<Task>, CancellationToken) action cancellationToken 전달하지 않습니다.

반환

Task

function반환된 작업의 프록시를 나타내는 작업입니다.

예외

ArgumentNullException

function 매개 변수가 null.

OperationCanceledException

작업이 취소되었습니다. 이 예외는 반환된 작업에 저장됩니다.

ObjectDisposedException

cancellationToken 연결된 CancellationTokenSource 삭제되었습니다.

TaskCanceledException

작업이 취소되었습니다.

설명

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

적용 대상

Run(Action, CancellationToken)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task 개체를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.

public:
 static System::Threading::Tasks::Task ^ Run(Action ^ action, System::Threading::CancellationToken cancellationToken);

public static System.Threading.Tasks.Task Run (Action action, System.Threading.CancellationToken cancellationToken);

static member Run : Action * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Public Shared Function Run (action As Action, cancellationToken As CancellationToken) As Task

매개 변수

action: Action

비동기적으로 실행할 작업입니다.

cancellationToken: CancellationToken

아직 시작하지 않은 경우 작업을 취소하는 데 사용할 수 있는 취소 토큰입니다. Run(Action, CancellationToken) action cancellationToken 전달하지 않습니다.

반환

Task

스레드 풀에서 실행하기 위해 대기 중인 작업을 나타내는 작업입니다.

예외

ArgumentNullException

action 매개 변수가 null.

OperationCanceledException

작업이 취소되었습니다. 이 예외는 반환된 작업에 저장됩니다.

ObjectDisposedException

cancellationToken 연결된 CancellationTokenSource 삭제되었습니다.

TaskCanceledException

작업이 취소되었습니다.

예제

다음 예제에서는 Run(Action, CancellationToken) 메서드를 호출하여 C:\Windows\System32 디렉터리에서 파일을 반복하는 작업을 만듭니다. 람다 식은 Parallel.ForEach 메서드를 호출하여 각 파일에 대한 정보를 List<T> 개체에 추가합니다. Parallel.ForEach 루프에서 호출하는 분리된 중첩된 각 작업은 취소 토큰의 상태를 확인하고 취소가 요청되면 CancellationToken.ThrowIfCancellationRequested 메서드를 호출합니다. CancellationToken.ThrowIfCancellationRequested 메서드는 호출 스레드가 Task.Wait 메서드를 호출할 때 catch 블록에서 처리되는 OperationCanceledException 예외를 throw합니다.

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

public class Example
{
   public static async Task Main()
   {
      var tokenSource = new CancellationTokenSource();
      var token = tokenSource.Token;
      var files = new List<Tuple<string, string, long, DateTime>>();

      var t = Task.Run( () => { string dir = "C:\\Windows\\System32\\";
                                object obj = new Object();
                                if (Directory.Exists(dir)) {
                                   Parallel.ForEach(Directory.GetFiles(dir),
                                   f => {
                                           if (token.IsCancellationRequested)
                                              token.ThrowIfCancellationRequested();
                                           var fi = new FileInfo(f);
                                           lock(obj) {
                                              files.Add(Tuple.Create(fi.Name, fi.DirectoryName, fi.Length, fi.LastWriteTimeUtc));          
                                           }
                                      });
                                 }
                              }
                        , token);
      await Task.Yield();
      tokenSource.Cancel();
      try {
         await t;
         Console.WriteLine("Retrieved information for {0} files.", files.Count);
      }
      catch (AggregateException e) {
         Console.WriteLine("Exception messages:");
         foreach (var ie in e.InnerExceptions)
            Console.WriteLine("   {0}: {1}", ie.GetType().Name, ie.Message);

         Console.WriteLine("\nTask status: {0}", t.Status);       
      }
      finally {
         tokenSource.Dispose();
      }
   }
}
// The example displays the following output:
//       Exception messages:
//          TaskCanceledException: A task was canceled.
//          TaskCanceledException: A task was canceled.
//          ...
//       
//       Task status: Canceled

open System
open System.IO
open System.Threading
open System.Threading.Tasks

let main =
    task {
        use tokenSource = new CancellationTokenSource()
        let token = tokenSource.Token
        let files = ResizeArray()

        let t =
            Task.Run(
                (fun () ->
                    let dir = "C:\\Windows\\System32\\"
                    let obj = obj ()

                    if Directory.Exists dir then
                        Parallel.ForEach(
                            Directory.GetFiles dir,
                            (fun f ->
                                if token.IsCancellationRequested then
                                    token.ThrowIfCancellationRequested()

                                let fi = FileInfo f
                                lock obj (fun () -> files.Add(fi.Name, fi.DirectoryName, fi.Length, fi.LastWriteTimeUtc)))
                        )
                        |> ignore),
                token
            )

        do! Task.Yield()
        tokenSource.Cancel()

        try
            do! t
            printfn $"Retrieved information for {files.Count} files."

        with :? AggregateException as e ->
            printfn "Exception messages:"

            for ie in e.InnerExceptions do
                printfn $"   {ie.GetType().Name}: {ie.Message}"

            printfn $"Task status: {t.Status}"
    }

main.Wait()


// The example displays the following output:
//       Exception messages:
//          TaskCanceledException: A task was canceled.
//          TaskCanceledException: A task was canceled.
//          ...
//
//       Task status: Canceled

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

Module Example
   Public Sub Main()
      Dim tokenSource As New CancellationTokenSource()
      Dim token As CancellationToken = tokenSource.Token
      Dim files As New List(Of Tuple(Of String, String, Long, Date))()

      Dim t As Task = Task.Run( Sub()
                                   Dim dir As String = "C:\Windows\System32\"
                                   Dim obj As New Object()
                                   If Directory.Exists(dir)Then
                                      Parallel.ForEach(Directory.GetFiles(dir), 
                                         Sub(f)
                                            If token.IsCancellationRequested Then
                                               token.ThrowIfCancellationRequested()
                                            End If  
                                            Dim fi As New FileInfo(f)
                                            SyncLock(obj)
                                              files.Add(Tuple.Create(fi.Name, fi.DirectoryName, fi.Length, fi.LastWriteTimeUtc))          
                                            End SyncLock
                                         End Sub)
                                   End If
                                End Sub, token)
      tokenSource.Cancel()
      Try
         t.Wait() 
         Console.WriteLine("Retrieved information for {0} files.", files.Count)
      Catch e As AggregateException
         Console.WriteLine("Exception messages:")
         For Each ie As Exception In e.InnerExceptions
            Console.WriteLine("   {0}:{1}", ie.GetType().Name, ie.Message)
         Next
         Console.WriteLine()
         Console.WriteLine("Task status: {0}", t.Status)       
      Finally
         tokenSource.Dispose()
      End Try
   End Sub
End Module
' The example displays the following output:
'       Exception messages:
'          TaskCanceledException: A task was canceled.
'       
'       Task status: Canceled

설명

태스크가 실행을 시작하기 전에 취소가 요청되면 태스크가 실행되지 않습니다. 대신 Canceled 상태로 설정되고 TaskCanceledException 예외가 throw됩니다.

Run(Action, CancellationToken) 메서드는 TaskFactory.StartNew(Action, CancellationToken) 메서드에 대한 더 간단한 대안입니다. 다음과 같은 기본값을 사용하여 작업을 만듭니다.

해당 CreationOptions 속성 값은 TaskCreationOptions.DenyChildAttach.
기본 작업 스케줄러를 사용합니다.

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

예외 처리(작업 병렬 라이브러리)

적용 대상

Run(Func<Task>)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 function반환된 작업에 대한 프록시를 반환합니다.

public:
 static System::Threading::Tasks::Task ^ Run(Func<System::Threading::Tasks::Task ^> ^ function);

public static System.Threading.Tasks.Task Run (Func<System.Threading.Tasks.Task> function);

public static System.Threading.Tasks.Task Run (Func<System.Threading.Tasks.Task?> function);

static member Run : Func<System.Threading.Tasks.Task> -> System.Threading.Tasks.Task

Public Shared Function Run (function As Func(Of Task)) As Task

매개 변수

function: Func<Task>

비동기적으로 실행할 작업입니다.

반환

Task

function반환된 작업의 프록시를 나타내는 작업입니다.

예외

ArgumentNullException

function 매개 변수가 null.

설명

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

예외 처리(작업 병렬 라이브러리)

적용 대상

Run(Action)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task 개체를 반환합니다.

public:
 static System::Threading::Tasks::Task ^ Run(Action ^ action);

public static System.Threading.Tasks.Task Run (Action action);

static member Run : Action -> System.Threading.Tasks.Task

Public Shared Function Run (action As Action) As Task

매개 변수

action: Action

비동기적으로 실행할 작업입니다.

반환

Task

ThreadPool에서 실행하기 위해 대기 중인 작업을 나타내는 작업입니다.

예외

ArgumentNullException

action 매개 변수가 null.

예제

다음 예제에서는 현재 스레드의 Thread.ManagedThreadId 표시하는 ShowThreadInfo 메서드를 정의합니다. 애플리케이션 스레드에서 직접 호출되고 Run(Action) 메서드에 전달된 Action 대리자에서 호출됩니다.

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

public class Example
{
   public static void Main()
   {
      ShowThreadInfo("Application");

      var t = Task.Run(() => ShowThreadInfo("Task") );
      t.Wait();
   }

   static void ShowThreadInfo(String s)
   {
      Console.WriteLine("{0} thread ID: {1}",
                        s, Thread.CurrentThread.ManagedThreadId);
   }
}
// The example displays the following output:
//       Application thread ID: 1
//       Task thread ID: 3

open System.Threading
open System.Threading.Tasks

let showThreadInfo s =
    printfn $"%s{s} thread ID: {Thread.CurrentThread.ManagedThreadId}"

showThreadInfo "Application"

let t = Task.Run(fun () -> showThreadInfo "Task")
t.Wait()

// The example displays the following output:
//       Application thread ID: 1
//       Task thread ID: 3

Imports System.Threading
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      ShowThreadInfo("Application")

      Dim t As Task = Task.Run(Sub() ShowThreadInfo("Task") )
      t.Wait()
   End Sub
   
   Private Sub ShowThreadInfo(s As String)
      Console.WriteLine("{0} Thread ID: {1}",
                        s, Thread.CurrentThread.ManagedThreadId)
   End Sub
End Module
' The example displays output like the following:
'    Application thread ID: 1
'    Task thread ID: 3

다음 예제는 람다 식을 사용하여 태스크가 실행할 코드를 정의한다는 점을 제외하고 이전 예제와 비슷합니다.

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

public class Example
{
   public static void Main()
   {
      Console.WriteLine("Application thread ID: {0}",
                        Thread.CurrentThread.ManagedThreadId);
      var t = Task.Run(() => {  Console.WriteLine("Task thread ID: {0}",
                                   Thread.CurrentThread.ManagedThreadId);
                             } );
      t.Wait();
   }
}
// The example displays the following output:
//       Application thread ID: 1
//       Task thread ID: 3

open System.Threading
open System.Threading.Tasks

printfn $"Application thread ID: {Thread.CurrentThread.ManagedThreadId}"
let t = Task.Run(fun () -> printfn $"Task thread ID: {Thread.CurrentThread.ManagedThreadId}")
t.Wait()

// The example displays the following output:
//       Application thread ID: 1
//       Task thread ID: 3

Imports System.Threading
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Console.WriteLine("Application thread ID: {0}",
                        Thread.CurrentThread.ManagedThreadId)
      Dim t As Task = Task.Run(Sub()
                                  Console.WriteLine("Task thread ID: {0}",
                                                    Thread.CurrentThread.ManagedThreadId)
                               End Sub)
      t.Wait()
   End Sub
End Module
' The example displays output like the following:
'    Application thread ID: 1
'    Task thread ID: 3

이 예제에서는 비동기 작업이 주 애플리케이션 스레드와 다른 스레드에서 실행되는 것을 보여 줍니다.

Wait 메서드를 호출하면 애플리케이션이 종료되기 전에 태스크가 완료되고 출력이 표시됩니다. 그렇지 않으면 작업이 완료되기 전에 Main 메서드가 완료될 수 있습니다.

다음 예제에서는 Run(Action) 메서드를 보여 줍니다. 디렉터리 이름의 배열을 정의하고 각 디렉터리에서 파일 이름을 검색하는 별도의 작업을 시작합니다. 모든 작업은 파일 이름을 단일 ConcurrentBag<T> 개체에 씁니다. 그런 다음, WaitAll(Task[]) 메서드를 호출하여 모든 작업이 완료되었는지 확인하고 ConcurrentBag<T> 개체에 기록된 총 파일 이름 수를 표시합니다.

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

public class Example
{
   public static void Main()
   {
      var list = new ConcurrentBag<string>();
      string[] dirNames = { ".", ".." };
      List<Task> tasks = new List<Task>();
      foreach (var dirName in dirNames) {
         Task t = Task.Run( () => { foreach(var path in Directory.GetFiles(dirName)) 
                                       list.Add(path); }  );
         tasks.Add(t);
      }
      Task.WaitAll(tasks.ToArray());
      foreach (Task t in tasks)
         Console.WriteLine("Task {0} Status: {1}", t.Id, t.Status);
         
      Console.WriteLine("Number of files read: {0}", list.Count);
   }
}
// The example displays output like the following:
//       Task 1 Status: RanToCompletion
//       Task 2 Status: RanToCompletion
//       Number of files read: 23

open System.Collections.Concurrent
open System.IO
open System.Threading.Tasks

let list = ConcurrentBag<string>()
let dirNames = [ "."; ".." ]
let tasks = ResizeArray()

for dirName in dirNames do
    let t =
        Task.Run(fun () ->
            for path in Directory.GetFiles dirName do
                list.Add path)

    tasks.Add t

tasks.ToArray() |> Task.WaitAll

for t in tasks do
    printfn $"Task {t.Id} Status: {t.Status}"

printfn $"Number of files read: {list.Count}"

// The example displays output like the following:
//       Task 1 Status: RanToCompletion
//       Task 2 Status: RanToCompletion
//       Number of files read: 23

Imports System.Collections.Concurrent
Imports System.Collections.Generic
Imports System.IO
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim list As New ConcurrentBag(Of String)()
      Dim dirNames() As String = { ".", ".." }
      Dim tasks As New List(Of Task)()
      For Each dirName In dirNames 
         Dim t As Task = Task.Run( Sub()
                                      For Each path In Directory.GetFiles(dirName) 
                                         list.Add(path)
                                      Next
                                   End Sub  )
         tasks.Add(t)
      Next
      Task.WaitAll(tasks.ToArray())
      For Each t In tasks
         Console.WriteLine("Task {0} Status: {1}", t.Id, t.Status)
      Next   
      Console.WriteLine("Number of files read: {0}", list.Count)
   End Sub
End Module
' The example displays output like the following:
'       Task 1 Status: RanToCompletion
'       Task 2 Status: RanToCompletion
'       Number of files read: 23

설명

Run 메서드를 사용하면 단일 메서드 호출에서 태스크를 만들고 실행할 수 있으며 StartNew 메서드의 더 간단한 대안입니다. 다음과 같은 기본값을 사용하여 작업을 만듭니다.

취소 토큰은 CancellationToken.None.
해당 CreationOptions 속성 값은 TaskCreationOptions.DenyChildAttach.
기본 작업 스케줄러를 사용합니다.

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

예외 처리(작업 병렬 라이브러리)

적용 대상

Run<TResult>(Func<Task<TResult>>)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 function반환된 Task(TResult) 대한 프록시를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<TResult> ^ Run(Func<System::Threading::Tasks::Task<TResult> ^> ^ function);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<System.Threading.Tasks.Task<TResult>> function);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<System.Threading.Tasks.Task<TResult>?> function);

static member Run : Func<System.Threading.Tasks.Task<'Result>> -> System.Threading.Tasks.Task<'Result>

Public Shared Function Run(Of TResult) (function As Func(Of Task(Of TResult))) As Task(Of TResult)

형식 매개 변수

TResult

프록시 태스크에서 반환된 결과의 형식입니다.

매개 변수

function: Func<Task<TResult>>

비동기적으로 실행할 작업입니다.

반환

Task<TResult>

function반환된 Task(TResult) 대한 프록시를 나타내는 Task(TResult).

예외

ArgumentNullException

function 매개 변수가 null.

설명

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

예외 처리(작업 병렬 라이브러리)

적용 대상

Run<TResult>(Func<TResult>)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task<TResult> 개체를 반환합니다. 취소 토큰을 사용하면 작업이 아직 시작되지 않은 경우 작업을 취소할 수 있습니다.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<TResult> ^ Run(Func<TResult> ^ function);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<TResult> function);

static member Run : Func<'Result> -> System.Threading.Tasks.Task<'Result>

Public Shared Function Run(Of TResult) (function As Func(Of TResult)) As Task(Of TResult)

형식 매개 변수

TResult

작업의 반환 형식입니다.

매개 변수

function: Func<TResult>

비동기적으로 실행할 작업입니다.

반환

Task<TResult>

스레드 풀에서 실행하기 위해 대기 중인 작업을 나타내는 작업 개체입니다.

예외

ArgumentNullException

function 매개 변수가 null.

예제

다음 예제에서는 게시된 책을 나타내는 텍스트 파일의 대략적인 단어 수를 계산합니다. 각 태스크는 파일을 열고, 전체 내용을 비동기적으로 읽고, 정규식을 사용하여 단어 개수를 계산합니다. WaitAll(Task[]) 메서드는 콘솔에 각 책의 단어 개수를 표시하기 전에 모든 작업이 완료되었는지 확인하기 위해 호출됩니다.

using System;
using System.IO;
using System.Text.RegularExpressions;
using System.Threading.Tasks;

public class Example
{
   public static void Main()
   {
      string pattern = @"\p{P}*\s+";
      string[] titles = { "Sister Carrie", "The Financier" };
      Task<int>[] tasks = new Task<int>[titles.Length];

      for (int ctr = 0; ctr < titles.Length; ctr++) {
         string s = titles[ctr];
         tasks[ctr] = Task.Run( () => {
                                   // Number of words.
                                   int nWords = 0;
                                   // Create filename from title.
                                   string fn = s + ".txt";
                                   if (File.Exists(fn)) {
                                      StreamReader sr = new StreamReader(fn);
                                      string input = sr.ReadToEndAsync().Result;
                                      nWords = Regex.Matches(input, pattern).Count;
                                   }
                                   return nWords;
                                } );
      }
      Task.WaitAll(tasks);

      Console.WriteLine("Word Counts:\n");
      for (int ctr = 0; ctr < titles.Length; ctr++)
         Console.WriteLine("{0}: {1,10:N0} words", titles[ctr], tasks[ctr].Result);
   }
}
// The example displays the following output:
//       Sister Carrie:    159,374 words
//       The Financier:    196,362 words

open System
open System.IO
open System.Text.RegularExpressions
open System.Threading.Tasks

let pattern = @"\p{P}*\s+"
let titles = [| "Sister Carrie"; "The Financier" |]

let tasks =
    Array.map (fun title ->
        Task.Run(fun () ->
            // Create filename from title.
            let fn = title + ".txt"

            if File.Exists fn then
                use sr = new StreamReader(fn)
                let input = sr.ReadToEndAsync().Result
                Regex.Matches(input, pattern).Count
            else
                0)) titles

tasks |> Seq.cast |> Array.ofSeq |> Task.WaitAll

printfn "Word Counts:\n"

for i = 0 to tasks.Length - 1 do
    printfn $"%s{titles.[i]}: %10d{tasks.[i].Result} words"

// The example displays the following output:
//       Sister Carrie:    159,374 words
//       The Financier:    196,362 words

Imports System.IO
Imports System.Text.RegularExpressions
Imports System.Threading.Tasks

Module Example
   Public Sub Main()
      Dim pattern As String = "\p{P}*\s+"
      Dim titles() As String = { "Sister Carrie",
                                 "The Financier" }
      Dim tasks(titles.Length - 1) As Task(Of Integer)

      For ctr As Integer = 0 To titles.Length - 1
         Dim s As String = titles(ctr)
         tasks(ctr) = Task.Run( Function()
                                   ' Number of words.
                                   Dim nWords As Integer = 0
                                   ' Create filename from title.
                                   Dim fn As String = s + ".txt"
                                   If File.Exists(fn) Then
                                      Dim sr As New StreamReader(fn)
                                      Dim input As String = sr.ReadToEndAsync().Result
                                      nWords = Regex.Matches(input, pattern).Count
                                   End If
                                   Return nWords
                                End Function)
      Next
      Task.WaitAll(tasks)

      Console.WriteLine("Word Counts:")
      Console.WriteLine()
      For ctr As Integer = 0 To titles.Length - 1
         Console.WriteLine("{0}: {1,10:N0} words", titles(ctr), tasks(ctr).Result)
      Next
   End Sub
End Module
' The example displays the following output:
'       Sister Carrie:    159,374 words
'       The Financier:    196,362 words

정규식 \p{P}*\s+ 0개, 하나 이상의 문장 부호 문자와 하나 이상의 공백 문자를 찾습니다. 일치 항목의 총 수가 대략적인 단어 개수와 같다고 가정합니다.

설명

Run 메서드는 TaskFactory.StartNew(Action) 메서드에 대한 더 간단한 대안입니다. 다음과 같은 기본값을 사용하여 작업을 만듭니다.

취소 토큰은 CancellationToken.None.
해당 CreationOptions 속성 값은 TaskCreationOptions.DenyChildAttach.
기본 작업 스케줄러를 사용합니다.

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

예외 처리(작업 병렬 라이브러리)

적용 대상

Run<TResult>(Func<Task<TResult>>, CancellationToken)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 function반환된 Task(TResult) 대한 프록시를 반환합니다.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<TResult> ^ Run(Func<System::Threading::Tasks::Task<TResult> ^> ^ function, System::Threading::CancellationToken cancellationToken);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<System.Threading.Tasks.Task<TResult>> function, System.Threading.CancellationToken cancellationToken);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<System.Threading.Tasks.Task<TResult>?> function, System.Threading.CancellationToken cancellationToken);

static member Run : Func<System.Threading.Tasks.Task<'Result>> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<'Result>

Public Shared Function Run(Of TResult) (function As Func(Of Task(Of TResult)), cancellationToken As CancellationToken) As Task(Of TResult)

형식 매개 변수

TResult

프록시 태스크에서 반환된 결과의 형식입니다.

매개 변수

function: Func<Task<TResult>>

비동기적으로 실행할 작업입니다.

cancellationToken: CancellationToken

아직 시작하지 않은 경우 작업을 취소하는 데 사용할 수 있는 취소 토큰입니다. Run<TResult>(Func<Task<TResult>>, CancellationToken) action cancellationToken 전달하지 않습니다.

반환

Task<TResult>

function반환된 Task(TResult) 대한 프록시를 나타내는 Task(TResult).

예외

ArgumentNullException

function 매개 변수가 null.

OperationCanceledException

작업이 취소되었습니다. 이 예외는 반환된 작업에 저장됩니다.

ObjectDisposedException

cancellationToken 연결된 CancellationTokenSource 삭제되었습니다.

TaskCanceledException

작업이 취소되었습니다.

설명

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

적용 대상

Run<TResult>(Func<TResult>, CancellationToken)

Source:: Task.cs

Source:: Task.cs

Source:: Task.cs

스레드 풀에서 실행할 지정된 작업을 큐에 대기하고 해당 작업을 나타내는 Task(TResult) 개체를 반환합니다.

public:
generic <typename TResult>
 static System::Threading::Tasks::Task<TResult> ^ Run(Func<TResult> ^ function, System::Threading::CancellationToken cancellationToken);

public static System.Threading.Tasks.Task<TResult> Run<TResult> (Func<TResult> function, System.Threading.CancellationToken cancellationToken);

static member Run : Func<'Result> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<'Result>

Public Shared Function Run(Of TResult) (function As Func(Of TResult), cancellationToken As CancellationToken) As Task(Of TResult)

형식 매개 변수

TResult

작업의 결과 형식입니다.

매개 변수

function: Func<TResult>

비동기적으로 실행할 작업입니다.

cancellationToken: CancellationToken

아직 시작하지 않은 경우 작업을 취소하는 데 사용할 수 있는 취소 토큰입니다. Run<TResult>(Func<TResult>, CancellationToken) action cancellationToken 전달하지 않습니다.

반환

Task<TResult>

스레드 풀에서 실행하기 위해 대기 중인 작업을 나타내는 Task(TResult).

예외

ArgumentNullException

function 매개 변수가 null.

OperationCanceledException

작업이 취소되었습니다. 이 예외는 반환된 작업에 저장됩니다.

ObjectDisposedException

cancellationToken 연결된 CancellationTokenSource 삭제되었습니다.

TaskCanceledException

작업이 취소되었습니다.

예제

다음 예제에서는 카운터가 2백만 값으로 증가될 때까지 반복되는 20개 작업을 만듭니다. 처음 10개 작업이 200만에 도달하면 취소 토큰이 취소되고 카운터가 200만 개에 도달하지 않은 모든 작업이 취소됩니다. 이 예제에서는 가능한 출력을 보여줍니다.

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

public class Example
{
   public static void Main()
   {
      var tasks = new List<Task<int>>();
      var source = new CancellationTokenSource();
      var token = source.Token;
      int completedIterations = 0;

      for (int n = 0; n <= 19; n++)
         tasks.Add(Task.Run( () => { int iterations = 0;
                                     for (int ctr = 1; ctr <= 2000000; ctr++) {
                                         token.ThrowIfCancellationRequested();
                                         iterations++;
                                     }
                                     Interlocked.Increment(ref completedIterations);
                                     if (completedIterations >= 10)
                                        source.Cancel();
                                     return iterations; }, token));

      Console.WriteLine("Waiting for the first 10 tasks to complete...\n");
      try  {
         Task.WaitAll(tasks.ToArray());
      }
      catch (AggregateException) {
         Console.WriteLine("Status of tasks:\n");
         Console.WriteLine("{0,10} {1,20} {2,14:N0}", "Task Id",
                           "Status", "Iterations");
         foreach (var t in tasks)
            Console.WriteLine("{0,10} {1,20} {2,14}",
                              t.Id, t.Status,
                              t.Status != TaskStatus.Canceled ? t.Result.ToString("N0") : "n/a");
      }
   }
}
// The example displays output like the following:
//    Waiting for the first 10 tasks to complete...
//    Status of tasks:
//
//       Task Id               Status     Iterations
//             1      RanToCompletion      2,000,000
//             2      RanToCompletion      2,000,000
//             3      RanToCompletion      2,000,000
//             4      RanToCompletion      2,000,000
//             5      RanToCompletion      2,000,000
//             6      RanToCompletion      2,000,000
//             7      RanToCompletion      2,000,000
//             8      RanToCompletion      2,000,000
//             9      RanToCompletion      2,000,000
//            10             Canceled            n/a
//            11             Canceled            n/a
//            12             Canceled            n/a
//            13             Canceled            n/a
//            14             Canceled            n/a
//            15             Canceled            n/a
//            16      RanToCompletion      2,000,000
//            17             Canceled            n/a
//            18             Canceled            n/a
//            19             Canceled            n/a
//            20             Canceled            n/a

open System
open System.Collections.Generic
open System.Threading
open System.Threading.Tasks

let source = new CancellationTokenSource()
let token = source.Token
let mutable completedIterations = 0

let tasks =
    [| for _ = 0 to 19 do
           Task.Run(
               (fun () ->
                   let mutable iterations = 0

                   for _ = 1 to 2000000 do
                       token.ThrowIfCancellationRequested()
                       iterations <- iterations + 1

                   Interlocked.Increment &completedIterations |> ignore

                   if completedIterations >= 10 then
                       source.Cancel()

                   iterations),
               token
           )

       |]

printfn "Waiting for the first 10 tasks to complete...\n"

try
    tasks |> Seq.cast |> Array.ofSeq |> Task.WaitAll
with :? AggregateException ->
    printfn "Status of tasks:\n"
    printfn "%10s %20s %14s" "Task Id" "Status" "Iterations"

    for t in tasks do
        if t.Status <> TaskStatus.Canceled then
            t.Result.ToString "N0"
        else
            "n/a"
        |> printfn "%10i %20O %14s" t.Id t.Status


// The example displays output like the following:
//    Waiting for the first 10 tasks to complete...
//    Status of tasks:
//
//       Task Id               Status     Iterations
//             1      RanToCompletion      2,000,000
//             2      RanToCompletion      2,000,000
//             3      RanToCompletion      2,000,000
//             4      RanToCompletion      2,000,000
//             5      RanToCompletion      2,000,000
//             6      RanToCompletion      2,000,000
//             7      RanToCompletion      2,000,000
//             8      RanToCompletion      2,000,000
//             9      RanToCompletion      2,000,000
//            10             Canceled            n/a
//            11             Canceled            n/a
//            12             Canceled            n/a
//            13             Canceled            n/a
//            14             Canceled            n/a
//            15             Canceled            n/a
//            16      RanToCompletion      2,000,000
//            17             Canceled            n/a
//            18             Canceled            n/a
//            19             Canceled            n/a
//            20             Canceled            n/a

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

Module Example

   Public Sub Main()
      Dim tasks As New List(Of Task(Of Integer))()
      Dim source As New CancellationTokenSource
      Dim token As CancellationToken = source.Token
      Dim completedIterations As Integer = 0
      
      For n As Integer = 0 To 19
         tasks.Add(Task.Run( Function()
                                Dim iterations As Integer= 0
                                For ctr As Long = 1 To 2000000
                                   token.ThrowIfCancellationRequested()
                                   iterations += 1
                                Next
                                Interlocked.Increment(completedIterations)
                                If completedIterations >= 10 Then source.Cancel()
                                Return iterations
                             End Function, token))
      Next

      Console.WriteLine("Waiting for the first 10 tasks to complete... ")
      Try
         Task.WaitAll(tasks.ToArray())
      Catch e As AggregateException
         Console.WriteLine("Status of tasks:")
         Console.WriteLine()
         Console.WriteLine("{0,10} {1,20} {2,14}", "Task Id",
                           "Status", "Iterations")
         For Each t In tasks
            Console.WriteLine("{0,10} {1,20} {2,14}",
                              t.Id, t.Status,
                              If(t.Status <> TaskStatus.Canceled,
                                 t.Result.ToString("N0"), "n/a"))
         Next
      End Try
   End Sub
End Module
' The example displays output like the following:
'    Waiting for the first 10 tasks to complete...
'    Status of tasks:
'
'       Task Id               Status     Iterations
'             1      RanToCompletion      2,000,000
'             2      RanToCompletion      2,000,000
'             3      RanToCompletion      2,000,000
'             4      RanToCompletion      2,000,000
'             5      RanToCompletion      2,000,000
'             6      RanToCompletion      2,000,000
'             7      RanToCompletion      2,000,000
'             8      RanToCompletion      2,000,000
'             9      RanToCompletion      2,000,000
'            10             Canceled            n/a
'            11             Canceled            n/a
'            12             Canceled            n/a
'            13             Canceled            n/a
'            14             Canceled            n/a
'            15             Canceled            n/a
'            16      RanToCompletion      2,000,000
'            17             Canceled            n/a
'            18             Canceled            n/a
'            19             Canceled            n/a
'            20             Canceled            n/a

이 예제에서는 InnerExceptions 속성을 사용하여 예외를 검사하는 대신 모든 작업을 반복하여 성공적으로 완료된 작업과 취소된 작업을 확인합니다. 완료된 작업의 경우 태스크에서 반환된 값을 표시합니다.

취소는 협조적이므로 각 작업에서 취소에 대응하는 방법을 결정할 수 있습니다. 다음 예제는 토큰이 취소되면 태스크가 예외를 throw하지 않고 완료한 반복 횟수를 반환한다는 점을 제외하고 첫 번째 예제와 같습니다.

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

public class Example
{
   public static void Main()
   {
      var tasks = new List<Task<int>>();
      var source = new CancellationTokenSource();
      var token = source.Token;
      int completedIterations = 0;

      for (int n = 0; n <= 19; n++)
         tasks.Add(Task.Run( () => { int iterations = 0;
                                     for (int ctr = 1; ctr <= 2000000; ctr++) {
                                         if (token.IsCancellationRequested)
                                            return iterations;
                                         iterations++;
                                     }
                                     Interlocked.Increment(ref completedIterations);
                                     if (completedIterations >= 10)
                                        source.Cancel();
                                     return iterations; }, token));

      Console.WriteLine("Waiting for the first 10 tasks to complete...\n");
      try  {
         Task.WaitAll(tasks.ToArray());
      }
      catch (AggregateException) {
         Console.WriteLine("Status of tasks:\n");
         Console.WriteLine("{0,10} {1,20} {2,14:N0}", "Task Id",
                           "Status", "Iterations");
         foreach (var t in tasks)
            Console.WriteLine("{0,10} {1,20} {2,14}",
                              t.Id, t.Status,
                              t.Status != TaskStatus.Canceled ? t.Result.ToString("N0") : "n/a");
      }
   }
}
// The example displays output like the following:
//    Status of tasks:
//
//       Task Id               Status     Iterations
//             1      RanToCompletion      2,000,000
//             2      RanToCompletion      2,000,000
//             3      RanToCompletion      2,000,000
//             4      RanToCompletion      2,000,000
//             5      RanToCompletion      2,000,000
//             6      RanToCompletion      2,000,000
//             7      RanToCompletion      2,000,000
//             8      RanToCompletion      2,000,000
//             9      RanToCompletion      2,000,000
//            10      RanToCompletion      1,658,326
//            11      RanToCompletion      1,988,506
//            12      RanToCompletion      2,000,000
//            13      RanToCompletion      1,942,246
//            14      RanToCompletion        950,108
//            15      RanToCompletion      1,837,832
//            16      RanToCompletion      1,687,182
//            17      RanToCompletion        194,548
//            18             Canceled    Not Started
//            19             Canceled    Not Started
//            20             Canceled    Not Started

open System
open System.Collections.Generic
open System.Threading
open System.Threading.Tasks

let source = new CancellationTokenSource()
let token = source.Token
let mutable completedIterations = 0

let tasks =
    [| for _ = 0 to 19 do
           Task.Run(
               (fun () ->
                   let mutable iterations = 0

                   for _ = 1 to 2000000 do
                       token.ThrowIfCancellationRequested()
                       iterations <- iterations + 1

                   Interlocked.Increment &completedIterations |> ignore

                   if completedIterations >= 10 then
                       source.Cancel()

                   iterations),
               token
           ) |]

printfn "Waiting for the first 10 tasks to complete...\n"

try
    tasks |> Seq.cast |> Array.ofSeq |> Task.WaitAll

with :? AggregateException ->
    printfn "Status of tasks:\n"
    printfn "%10s %20s %14s" "Task Id" "Status" "Iterations"

    for t in tasks do
        if t.Status <> TaskStatus.Canceled then
            t.Result.ToString "N0"
        else
            "n/a"
        |> printfn "%10i %20O %14s" t.Id t.Status

// The example displays output like the following:
//    Status of tasks:
//
//       Task Id               Status     Iterations
//             1      RanToCompletion      2,000,000
//             2      RanToCompletion      2,000,000
//             3      RanToCompletion      2,000,000
//             4      RanToCompletion      2,000,000
//             5      RanToCompletion      2,000,000
//             6      RanToCompletion      2,000,000
//             7      RanToCompletion      2,000,000
//             8      RanToCompletion      2,000,000
//             9      RanToCompletion      2,000,000
//            10      RanToCompletion      1,658,326
//            11      RanToCompletion      1,988,506
//            12      RanToCompletion      2,000,000
//            13      RanToCompletion      1,942,246
//            14      RanToCompletion        950,108
//            15      RanToCompletion      1,837,832
//            16      RanToCompletion      1,687,182
//            17      RanToCompletion        194,548
//            18             Canceled    Not Started
//            19             Canceled    Not Started
//            20             Canceled    Not Started

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

Module Example

   Public Sub Main()
      Dim tasks As New List(Of Task(Of Integer))()
      Dim source As New CancellationTokenSource
      Dim token As CancellationToken = source.Token
      Dim completedIterations As Integer = 0
      
      For n As Integer = 0 To 19
         tasks.Add(Task.Run( Function()
                                Dim iterations As Integer= 0
                                For ctr As Long = 1 To 2000000
                                   If token.IsCancellationRequested Then
                                      Return iterations
                                   End If
                                   iterations += 1
                                Next
                                Interlocked.Increment(completedIterations)
                                If completedIterations >= 10 Then source.Cancel()
                                Return iterations
                             End Function, token))
      Next

      Try
         Task.WaitAll(tasks.ToArray())
      Catch e As AggregateException
         Console.WriteLine("Status of tasks:")
         Console.WriteLine()
         Console.WriteLine("{0,10} {1,20} {2,14:N0}", "Task Id",
                           "Status", "Iterations")
         For Each t In tasks
            Console.WriteLine("{0,10} {1,20} {2,14}",
                              t.Id, t.Status,
                              If(t.Status <> TaskStatus.Canceled,
                                 t.Result.ToString("N0"), "Not Started"))
         Next
      End Try
   End Sub
End Module
' The example displays output like the following:
'    Status of tasks:
'
'       Task Id               Status     Iterations
'             1      RanToCompletion      2,000,000
'             2      RanToCompletion      2,000,000
'             3      RanToCompletion      2,000,000
'             4      RanToCompletion      2,000,000
'             5      RanToCompletion      2,000,000
'             6      RanToCompletion      2,000,000
'             7      RanToCompletion      2,000,000
'             8      RanToCompletion      2,000,000
'             9      RanToCompletion      2,000,000
'            10      RanToCompletion      1,658,326
'            11      RanToCompletion      1,988,506
'            12      RanToCompletion      2,000,000
'            13      RanToCompletion      1,942,246
'            14      RanToCompletion        950,108
'            15      RanToCompletion      1,837,832
'            16      RanToCompletion      1,687,182
'            17      RanToCompletion        194,548
'            18             Canceled    Not Started
'            19             Canceled    Not Started
'            20             Canceled    Not Started

이 예제에서는 여전히 AggregateException 예외를 처리해야 합니다. 취소가 요청될 때 시작되지 않은 작업은 여전히 예외를 throw하기 때문에 발생합니다.

설명

태스크가 실행을 시작하기 전에 취소가 요청되면 태스크가 실행되지 않습니다. 대신 Canceled 상태로 설정되고 TaskCanceledException 예외가 throw됩니다.

Run 메서드는 StartNew 메서드에 대한 더 간단한 대안입니다. 다음과 같은 기본값을 사용하여 작업을 만듭니다.

해당 CreationOptions 속성 값은 TaskCreationOptions.DenyChildAttach.
기본 작업 스케줄러를 사용합니다.

작업 작업에서 throw된 예외 처리에 대한 자세한 내용은 예외 처리참조하세요.

추가 정보

적용 대상

다음을 통해 공유

Task.Run 메서드

정의

오버로드

설명

Run(Func<Task>, CancellationToken)

매개 변수

반환

예외

설명

추가 정보

적용 대상

Run(Action, CancellationToken)

매개 변수

반환

예외

예제

설명

추가 정보

적용 대상

Run(Func<Task>)

매개 변수

반환

예외

설명

추가 정보

적용 대상

Run(Action)

매개 변수

반환

예외

예제

설명

추가 정보

적용 대상

Run<TResult>(Func<Task<TResult>>)

형식 매개 변수

매개 변수

반환

예외

설명

추가 정보

적용 대상

Run<TResult>(Func<TResult>)

형식 매개 변수

매개 변수

반환

예외

예제

설명

추가 정보

적용 대상

Run<TResult>(Func<Task<TResult>>, CancellationToken)

형식 매개 변수

매개 변수

반환

예외

설명

추가 정보

적용 대상

Run<TResult>(Func<TResult>, CancellationToken)

형식 매개 변수

매개 변수

반환

예외

예제

설명

추가 정보

적용 대상

추가 리소스