TaskFactory.StartNew 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
创建并启动 任务。
重载
注解
从 .NET Framework 4.5 开始,Task.Run建议使用此方法启动计算绑定任务。 StartNew仅当需要对长时间运行的计算绑定任务进行精细控制时,才使用该方法。 这包括要控制以下内容的方案:
任务创建选项。 默认情况下, Task.Run 方法创建的任务是使用 TaskCreationOptions.DenyChildAttach 选项创建的。 若要重写此行为或提供其他 TaskCreationOptions 选项,请调用 StartNew 重载。
任务计划程序。 方法的 Task.Run 重载使用默认任务计划程序。 若要控制任务计划程序,请使用参数
scheduler
调用StartNew重载。 有关详细信息,请参阅 TaskScheduler。
StartNew(Action<Object>, Object, CancellationToken, TaskCreationOptions, TaskScheduler)
为指定的操作委托、状态、取消令牌、创建选项和任务计划程序创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action<System::Object ^> ^ action, System::Object ^ state, System::Threading::CancellationToken cancellationToken, System::Threading::Tasks::TaskCreationOptions creationOptions, System::Threading::Tasks::TaskScheduler ^ scheduler);
public System.Threading.Tasks.Task StartNew (Action<object> action, object state, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
public System.Threading.Tasks.Task StartNew (Action<object?> action, object? state, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
member this.StartNew : Action<obj> * obj * System.Threading.CancellationToken * System.Threading.Tasks.TaskCreationOptions * System.Threading.Tasks.TaskScheduler -> System.Threading.Tasks.Task
Public Function StartNew (action As Action(Of Object), state As Object, cancellationToken As CancellationToken, creationOptions As TaskCreationOptions, scheduler As TaskScheduler) As Task
参数
- state
- Object
一个包含由 action
委托使用的数据的对象。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
- scheduler
- TaskScheduler
用于计划所创建的任务的任务计划程序。
返回
已启动的任务。
例外
creationOptions
参数指定了一个无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其中一个构造函数创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action, CancellationToken, TaskCreationOptions, TaskScheduler)
为指定的操作委托、取消令牌、创建选项和状态创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action ^ action, System::Threading::CancellationToken cancellationToken, System::Threading::Tasks::TaskCreationOptions creationOptions, System::Threading::Tasks::TaskScheduler ^ scheduler);
public System.Threading.Tasks.Task StartNew (Action action, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
member this.StartNew : Action * System.Threading.CancellationToken * System.Threading.Tasks.TaskCreationOptions * System.Threading.Tasks.TaskScheduler -> System.Threading.Tasks.Task
Public Function StartNew (action As Action, cancellationToken As CancellationToken, creationOptions As TaskCreationOptions, scheduler As TaskScheduler) As Task
参数
- action
- Action
要异步执行的操作委托。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
- scheduler
- TaskScheduler
用于计划所创建的任务的任务计划程序。
返回
已启动的任务。
例外
creationOptions
指定了无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其中一个构造函数创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action<Object>, Object, TaskCreationOptions)
为指定的操作委托、状态和创建选项创建和启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action<System::Object ^> ^ action, System::Object ^ state, System::Threading::Tasks::TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task StartNew (Action<object> action, object state, System.Threading.Tasks.TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task StartNew (Action<object?> action, object? state, System.Threading.Tasks.TaskCreationOptions creationOptions);
member this.StartNew : Action<obj> * obj * System.Threading.Tasks.TaskCreationOptions -> System.Threading.Tasks.Task
Public Function StartNew (action As Action(Of Object), state As Object, creationOptions As TaskCreationOptions) As Task
参数
- state
- Object
一个包含由 action
委托使用的数据的对象。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
返回
已启动的任务。
例外
action
上声明的默认值为 null
。
creationOptions
指定了一个无效的 TaskCreationOptions 值。
注解
调用 StartNew 的功能等效于使用其中一个构造函数创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action<Object>, Object, CancellationToken)
为指定的动作委托、状态和取消标记创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action<System::Object ^> ^ action, System::Object ^ state, System::Threading::CancellationToken cancellationToken);
public System.Threading.Tasks.Task StartNew (Action<object> action, object state, System.Threading.CancellationToken cancellationToken);
public System.Threading.Tasks.Task StartNew (Action<object?> action, object? state, System.Threading.CancellationToken cancellationToken);
member this.StartNew : Action<obj> * obj * System.Threading.CancellationToken -> System.Threading.Tasks.Task
Public Function StartNew (action As Action(Of Object), state As Object, cancellationToken As CancellationToken) As Task
参数
- state
- Object
一个包含由 action
委托使用的数据的对象。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
返回
已启动的任务。
例外
action
上声明的默认值为 null
。
示例
以下示例定义 6 个字母单词的数组。 然后,每个单词都会 Action<T> 传递给委托,该委托会争用单词并显示原始单词及其拼码版本。
using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
CancellationTokenSource cts = new CancellationTokenSource();
CancellationToken token = cts.Token;
var tasks = new List<Task>();
Random rnd = new Random();
Object lockObj = new Object();
String[] words6 = { "reason", "editor", "rioter", "rental",
"senior", "regain", "ordain", "rained" };
foreach (var word6 in words6)
tasks.Add(Task.Factory.StartNew( (word) => { Char[] chars = word.ToString().ToCharArray();
double[] order = new double[chars.Length];
token.ThrowIfCancellationRequested();
bool wasZero = false;
lock (lockObj) {
for (int ctr = 0; ctr < order.Length; ctr++) {
order[ctr] = rnd.NextDouble();
if (order[ctr] == 0) {
if (! wasZero) {
wasZero = true;
}
else {
cts.Cancel();
}
}
}
}
token.ThrowIfCancellationRequested();
Array.Sort(order, chars);
Console.WriteLine("{0} --> {1}", word,
new String(chars));
}, word6, token));
try {
Task.WaitAll(tasks.ToArray());
}
catch (AggregateException e) {
foreach (var ie in e.InnerExceptions) {
if (ie is OperationCanceledException) {
Console.WriteLine("The word scrambling operation has been cancelled.");
break;
}
else {
Console.WriteLine(ie.GetType().Name + ": " + ie.Message);
}
}
}
finally {
cts.Dispose();
}
}
}
// The example displays output like the following:
// regain --> irnaeg
// ordain --> rioadn
// reason --> soearn
// rained --> rinade
// rioter --> itrore
// senior --> norise
// rental --> atnerl
// editor --> oteird
Imports System.Collections.Generic
Imports System.Threading
Imports System.Threading.Tasks
Module Example
Public Sub Main()
Dim cts As New CancellationTokenSource()
Dim token As CancellationToken = cts.Token
Dim tasks As New List(Of Task)()
Dim rnd As New Random()
Dim lockObj As New Object()
Dim words6() As String = { "reason", "editor", "rioter", "rental",
"senior", "regain", "ordain", "rained" }
For Each word6 in words6
tasks.Add(Task.Factory.StartNew( Sub(word)
Dim chars() As Char = word.ToString().ToCharArray()
Dim order(chars.Length - 1) As Double
Dim wasZero As Boolean = False
SyncLock lockObj
For ctr As Integer = 0 To order.Length - 1
order(ctr) = rnd.NextDouble()
If order(ctr) = 0 Then
If Not wasZero Then
wasZero = True
Else
cts.Cancel()
End If
End If
Next
End SyncLock
token.ThrowIfCancellationRequested()
Array.Sort(order, chars)
Console.WriteLine("{0} --> {1}", word,
new String(chars))
End Sub, word6))
Next
Try
Task.WaitAll(tasks.ToArray())
Catch e As AggregateException
For Each ie In e.InnerExceptions
If TypeOf ie Is OperationCanceledException
Console.WriteLine("The word scrambling operation has been cancelled.")
Exit For
Else
Console.WriteLine(ie.GetType().Name + ": " + ie.Message)
End If
Next
Finally
cts.Dispose()
End Try
End Sub
End Module
' The example displays output like the following:
' regain --> irnaeg
' ordain --> rioadn
' reason --> soearn
' rained --> rinade
' rioter --> itrore
' senior --> norise
' rental --> atnerl
' editor --> oteird
请注意,该示例初始化受锁保护的单个随机数生成器。 有关锁的需要,请参阅类主题中的 Random “System.Random 类和线程安全性”。 为了处理随机数生成器损坏的可能性,将取消令牌传递给任务。 如果两个随机数等于零,则该方法假定随机数生成器已损坏并设置取消标记。 在 chars
对包含单词中 6 个字符的数组进行排序之前,该方法调用 CancellationToken.ThrowIfCancellationRequested 该方法以引发 OperationCanceledException 标记(如果令牌已被取消)。
注解
调用 StartNew 的功能等效于使用其中一个构造函数创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action, CancellationToken)
为指定的动作委派和取消标记创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action ^ action, System::Threading::CancellationToken cancellationToken);
public System.Threading.Tasks.Task StartNew (Action action, System.Threading.CancellationToken cancellationToken);
member this.StartNew : Action * System.Threading.CancellationToken -> System.Threading.Tasks.Task
Public Function StartNew (action As Action, cancellationToken As CancellationToken) As Task
参数
- action
- Action
要异步执行的操作委托。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
返回
已启动的任务。
例外
action
上声明的默认值为 null
。
示例
以下示例调用StartNew(Action, CancellationToken)该方法以创建一个任务,该任务循环访问 C:\Windows\System32 目录中的文件。 lambda 表达式调用 Parallel.ForEach 该方法,以向对象添加有关每个文件 List<T> 的信息。 循环调用 Parallel.ForEach 的每个分离嵌套任务都会检查取消令牌的状态,如果请求取消,则调用该方法 CancellationToken.ThrowIfCancellationRequested 。 当调用线程调用Task.Wait该方法时,该方法CancellationToken.ThrowIfCancellationRequested将OperationCanceledException引发在catch
块中处理的异常。
using System;
using System.Collections.Generic;
using System.IO;
using System.Threading;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
var tokenSource = new CancellationTokenSource();
var token = tokenSource.Token;
var files = new List<Tuple<string, string, long, DateTime>>();
var t = Task.Factory.StartNew( () => { 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);
tokenSource.Cancel();
try {
t.Wait();
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.
//
// 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.Factory.StartNew( 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
注解
调用 StartNew
在功能上等效于使用其构造函数之一创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以使用Task.Run(Action, CancellationToken)该方法快速调用StartNew(Action, CancellationToken)默认参数。 但是,请注意,这两种方法在行为上存在差异: Task.Run(Action, CancellationToken) 默认情况下,不允许从选项开始 TaskCreationOptions.AttachedToParent 的子任务附加到当前 Task 实例,而 StartNew(Action, CancellationToken) 不允许子任务。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action, TaskCreationOptions)
为指定的操作委托和创建选项创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action ^ action, System::Threading::Tasks::TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task StartNew (Action action, System.Threading.Tasks.TaskCreationOptions creationOptions);
member this.StartNew : Action * System.Threading.Tasks.TaskCreationOptions -> System.Threading.Tasks.Task
Public Function StartNew (action As Action, creationOptions As TaskCreationOptions) As Task
参数
- action
- Action
要异步执行的操作委托。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
返回
已启动的任务。
例外
action
上声明的默认值为 null
。
creationOptions
指定了一个无效的 TaskCreationOptions 值。
注解
调用 StartNew 的功能等效于使用其中一个构造函数创建任务,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action)
为指定的操作委托创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action ^ action);
public System.Threading.Tasks.Task StartNew (Action action);
member this.StartNew : Action -> System.Threading.Tasks.Task
Public Function StartNew (action As Action) As Task
参数
- action
- Action
要异步执行的操作委托。
返回
已启动的任务。
例外
action
参数为 null
。
示例
下面的示例使用 StartNew(Action) 该方法重复调用 Action 生成随机数的委托,将其解释为 Unicode 代码点,将其转换为 UTF16 编码的代码单元,并显示有关生成的字符或字符的信息。
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
Random rnd = new Random();
List<Task> tasks = new List<Task>();
// Execute the task 10 times.
for (int ctr = 1; ctr <= 9; ctr++) {
tasks.Add(Task.Factory.StartNew( () => {
int utf32 = 0;
lock(rnd) {
// Get UTF32 value.
utf32 = rnd.Next(0, 0xE01F0);
}
// Convert it to a UTF16-encoded character.
string utf16 = Char.ConvertFromUtf32(utf32);
// Display information about the character.
Console.WriteLine("0x{0:X8} --> '{1,2}' ({2})",
utf32, utf16, ShowHex(utf16));
}));
}
Task.WaitAll(tasks.ToArray());
}
private static string ShowHex(string value)
{
string hexString = null;
// Handle only non-control characters.
if (! Char.IsControl(value, 0)) {
foreach (var ch in value)
hexString += $"0x{(ushort)ch:X} ";
}
return hexString.Trim();
}
}
// The example displays the following output:
// 0x00097103 --> '' (0x55836 0x56579)
// 0x000A98A1 --> '' (0x55910 0x56481)
// 0x00050002 --> '' (0x55552 0x56322)
// 0x0000FEF1 --> 'ﻱ' (0x65265)
// 0x0008BC0A --> '' (0x55791 0x56330)
// 0x000860EA --> '' (0x55768 0x56554)
// 0x0009AC5A --> '' (0x55851 0x56410)
// 0x00053320 --> '' (0x55564 0x57120)
// 0x000874EF --> '' (0x55773 0x56559)
Imports System.Collections.Generic
Imports System.Threading.Tasks
Public Module Example
Public Sub Main()
Dim rnd As New Random()
Dim tasks As New List(Of Task)
' Execute the task 10 times.
For ctr As Integer = 1 To 9
tasks.Add(Task.Factory.StartNew(Sub()
Dim utf32 As Integer
SyncLock(rnd)
' Get UTF32 value.
utf32 = rnd.Next(0, &hE01F0)
End SyncLock
' Convert it to a UTF16-encoded character.
Dim utf16 As String = Char.ConvertFromUtf32(utf32)
' Display information about the character.
Console.WriteLine("0x{0:X8} --> '{1,2}' ({2})",
utf32, utf16, ShowHex(utf16))
End Sub))
Next
Task.WaitAll(tasks.ToArray())
End Sub
Private Function ShowHex(value As String) As String
Dim hexString As String = Nothing
' Handle only non-control characters.
If Not Char.IsControl(value, 0) Then
For Each ch In value
hexString += String.Format("0x{0} ", Convert.ToUInt16(ch))
Next
End If
Return hexString.Trim()
End Function
End Module
' The example displays output similar to the following:
' 0x00097103 --> '' (0x55836 0x56579)
' 0x000A98A1 --> '' (0x55910 0x56481)
' 0x00050002 --> '' (0x55552 0x56322)
' 0x0000FEF1 --> 'ﻱ' (0x65265)
' 0x0008BC0A --> '' (0x55791 0x56330)
' 0x000860EA --> '' (0x55768 0x56554)
' 0x0009AC5A --> '' (0x55851 0x56410)
' 0x00053320 --> '' (0x55564 0x57120)
' 0x000874EF --> '' (0x55773 0x56559)
注解
调用 StartNew 的功能等效于使用其构造函数之一创建任务,然后调用 Task.Start 该方法来计划任务执行。
从 .NET Framework 4.5 开始,可以使用Task.Run(Action)该方法快速调用StartNew(Action)默认参数。 但是,请注意,这两种方法在行为上存在差异: Task.Run(Action) 默认情况下,不允许从选项开始 TaskCreationOptions.AttachedToParent 的子任务附加到当前 Task 实例,而 StartNew(Action) 不允许子任务。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew(Action<Object>, Object)
为指定的操作委托和状态创建并启动任务。
public:
System::Threading::Tasks::Task ^ StartNew(Action<System::Object ^> ^ action, System::Object ^ state);
public System.Threading.Tasks.Task StartNew (Action<object> action, object state);
public System.Threading.Tasks.Task StartNew (Action<object?> action, object? state);
member this.StartNew : Action<obj> * obj -> System.Threading.Tasks.Task
Public Function StartNew (action As Action(Of Object), state As Object) As Task
参数
- state
- Object
一个包含由 action
委托使用的数据的对象。
返回
已启动的任务。
例外
action
参数为 null
。
示例
以下示例定义 6 个字母单词的数组。 然后,每个单词都会 Action<T> 传递给委托,该委托会争用单词并显示原始单词及其拼码版本。
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
var tasks = new List<Task>();
Random rnd = new Random();
Object lockObj = new Object();
String[] words6 = { "reason", "editor", "rioter", "rental",
"senior", "regain", "ordain", "rained" };
foreach (var word6 in words6)
tasks.Add(Task.Factory.StartNew( (word) => { Char[] chars = word.ToString().ToCharArray();
double[] order = new double[chars.Length];
lock (lockObj) {
for (int ctr = 0; ctr < order.Length; ctr++)
order[ctr] = rnd.NextDouble();
}
Array.Sort(order, chars);
Console.WriteLine("{0} --> {1}", word,
new String(chars));
}, word6));
Task.WaitAll(tasks.ToArray());
}
}
// The example displays output like the following:
// regain --> irnaeg
// ordain --> rioadn
// reason --> soearn
// rained --> rinade
// rioter --> itrore
// senior --> norise
// rental --> atnerl
// editor --> oteird
Imports System.Collections.Generic
Imports System.Threading.Tasks
Module Example
Public Sub Main()
Dim tasks As New List(Of Task)()
Dim rnd As New Random()
Dim lockObj As New Object()
Dim words6() As String = { "reason", "editor", "rioter", "rental",
"senior", "regain", "ordain", "rained" }
For Each word6 in words6
tasks.Add(Task.Factory.StartNew( Sub(word)
Dim chars() As Char = word.ToString().ToCharArray()
Dim order(chars.Length - 1) As Double
SyncLock lockObj
For ctr As Integer = 0 To order.Length - 1
order(ctr) = rnd.NextDouble()
Next
End SyncLock
Array.Sort(order, chars)
Console.WriteLine("{0} --> {1}", word,
new String(chars))
End Sub, word6))
Next
Task.WaitAll(tasks.ToArray())
End Sub
End Module
' The example displays output like the following:
' regain --> irnaeg
' ordain --> rioadn
' reason --> soearn
' rained --> rinade
' rioter --> itrore
' senior --> norise
' rental --> atnerl
' editor --> oteird
请注意,该示例初始化受锁保护的单个随机数生成器。 有关锁的需要,请参阅类主题中的 Random “System.Random 类和线程安全性”。
注解
调用 StartNew 在功能上等效于使用其构造函数之一 Task 创建,然后调用 Start 该方法来计划执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程中的 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<TResult>, CancellationToken, TaskCreationOptions, TaskScheduler)
为指定的函数委托、取消标记、创建选项和任务计划程序创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<TResult> ^ function, System::Threading::CancellationToken cancellationToken, System::Threading::Tasks::TaskCreationOptions creationOptions, System::Threading::Tasks::TaskScheduler ^ scheduler);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<TResult> function, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
member this.StartNew : Func<'Result> * System.Threading.CancellationToken * System.Threading.Tasks.TaskCreationOptions * System.Threading.Tasks.TaskScheduler -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of TResult), cancellationToken As CancellationToken, creationOptions As TaskCreationOptions, scheduler As TaskScheduler) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- function
- Func<TResult>
一个函数委托,可返回能够通过任务获得的将来结果。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
- scheduler
- TaskScheduler
用于计划所创建的任务的任务计划程序。
返回
已启动的任务。
例外
creationOptions
指定了一个无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<TResult>)
为指定的函数委托创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<TResult> ^ function);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<TResult> function);
member this.StartNew : Func<'Result> -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of TResult)) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- function
- Func<TResult>
一个函数委托,可返回能够通过任务获得的将来结果。
返回
已启动的任务。
例外
function
参数为 null
。
示例
以下示例是一个简单的加法应用,它生成两个随机数,并提示用户输入其总和。 然后,它指示答案是否正确,或者,如果用户的响应不是有效号码,则提示用户重新输入有效号码。 用于 StartNew 创建 Task<TResult> 返回要添加的随机数的对象。
using System;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
Random rnd = new Random();
Task<int>[] tasks = new Task<int>[2];
Object obj = new Object();
while (true) {
for (int ctr = 0; ctr <= 1; ctr++)
tasks[ctr] = Task.Factory.StartNew(() => { int i = 0;
lock(obj) {
i = rnd.Next(101);
}
return i; });
Task.WaitAll(tasks);
int n1 = tasks[0].Result;
int n2 = tasks[1].Result;
int result = n1 + n2;
bool validInput = false;
while (! validInput) {
ShowMessage(n1, n2);
string userInput = Console.ReadLine();
// Process user input.
if (userInput.Trim().ToUpper() == "X") return;
int answer;
validInput = Int32.TryParse(userInput, out answer);
if (! validInput)
Console.WriteLine("Invalid input. Try again, but enter only numbers. ");
else if (answer == result)
Console.WriteLine("Correct!");
else
Console.WriteLine("Incorrect. The correct answer is {0}.", result);
}
}
}
private static void ShowMessage(int n1, int n2)
{
Console.WriteLine("\nEnter 'x' to exit...");
Console.Write("{0} + {1} = ", n1, n2);
}
}
// The example displays the following output:
// Enter 'x' to exit...
// 15 + 11 = 26
// Correct!
//
// Enter 'x' to exit...
// 75 + 33 = adc
// Invalid input. Try again, but enter only numbers.
//
// Enter 'x' to exit...
// 75 + 33 = 108
// Correct!
//
// Enter 'x' to exit...
// 67 + 55 = 133
// Incorrect. The correct answer is 122.
//
// Enter 'x' to exit...
// 92 + 51 = 133
// Incorrect. The correct answer is 143.
//
// Enter 'x' to exit...
// 81 + 65 = x
Imports System.Threading.Tasks
Module AdditionTester
Public Sub Main()
Dim rnd As New Random()
Dim tasks(1) As Task(Of Integer)
Dim obj As New Object()
Do While True
For ctr As Integer = 0 To 1
tasks(ctr) = Task.Factory.StartNew(Function()
Dim i As Integer
SyncLock(obj)
i = rnd.Next(101)
End SyncLock
Return i
End Function)
Next
Task.WaitAll(tasks)
Dim n1 As Integer = tasks(0).Result
Dim n2 As Integer = tasks(1).Result
Dim result As Integer = n1 + n2
Dim validInput As Boolean = False
Do While Not validInput
ShowMessage(n1, n2)
Dim userInput As String = Console.ReadLine()
' Process user input.
If userInput.Trim().ToUpper = "X" Then Exit Sub
Dim answer As Integer
validInput = Int32.TryParse(userInput, answer)
If Not validInput Then
Console.WriteLine("Invalid input. Try again, but enter only numbers. ")
Else If answer = result Then
Console.WriteLine("Correct!")
Else
Console.WriteLine("Incorrect. The correct answer is {0}.", result)
End If
Loop
Loop
End Sub
Private Sub ShowMessage(n1 As Integer, n2 As Integer)
Console.WriteLine()
Console.WriteLine("Enter 'x' to exit...")
Console.Write("{0} + {1} = ", n1, n2)
End Sub
End Module
' The example displays output like the following:
' Enter 'x' to exit...
' 15 + 11 = 26
' Correct!
'
' Enter 'x' to exit...
' 75 + 33 = adc
' Invalid input. Try again, but enter only numbers.
'
' Enter 'x' to exit...
' 75 + 33 = 108
' Correct!
'
' Enter 'x' to exit...
' 67 + 55 = 133
' Incorrect. The correct answer is 122.
'
' Enter 'x' to exit...
' 92 + 51 = 133
' Incorrect. The correct answer is 143.
'
' Enter 'x' to exit...
' 81 + 65 = x
注解
调用 StartNew 在功能上等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划执行。
从 .NET Framework 4.5 开始,可以快速调用Task.Run<TResult>(Func<TResult>)该方法,以使用默认参数进行调用StartNew。 但是,请注意,这两种方法在行为上存在差异: Task.Run<TResult>(Func<TResult>) 默认情况下,不允许从选项开始 TaskCreationOptions.AttachedToParent 的子任务附加到当前 Task<TResult> 实例,而 StartNew<TResult>(Func<TResult>) 不允许子任务。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<Object,TResult>, Object)
为指定的函数委托和状态创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<System::Object ^, TResult> ^ function, System::Object ^ state);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object,TResult> function, object state);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object?,TResult> function, object? state);
member this.StartNew : Func<obj, 'Result> * obj -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of Object, TResult), state As Object) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- state
- Object
一个包含由 function
委托使用的数据的对象。
返回
已启动的任务。
例外
function
上声明的默认值为 null
。
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<TResult>, CancellationToken)
为指定的函数委托和取消标记创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<TResult> ^ function, System::Threading::CancellationToken cancellationToken);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<TResult> function, System.Threading.CancellationToken cancellationToken);
member this.StartNew : Func<'Result> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of TResult), cancellationToken As CancellationToken) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- function
- Func<TResult>
一个函数委托,可返回能够通过任务获得的将来结果。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
返回
已启动的任务。
例外
function
上声明的默认值为 null
。
示例
以下示例使用两个任务计算以 F100 = F100-1 + F100-2 结尾且种子值为 F1= 1、F2 = 1 和 F1 = 0、F2= 1 的 Fibonacci 序列。 大约一半的时间,取消令牌设置为执行操作。 如果两个任务成功完成并且令牌被取消,则此示例的输出显示结果。
using System;
using System.Collections.Generic;
using System.Numerics;
using System.Threading;
using System.Threading.Tasks;
public class Example
{
public static void Main()
{
var rnd = new Random();
var tasks = new List<Task<BigInteger[]>>();
var source = new CancellationTokenSource();
var token = source.Token;
for (int ctr = 0; ctr <= 1; ctr++) {
int start = ctr;
tasks.Add(Task.Run( () => { BigInteger[] sequence = new BigInteger[100];
sequence[0] = start;
sequence[1] = 1;
for (int index = 2; index <= sequence.GetUpperBound(0); index++) {
token.ThrowIfCancellationRequested();
sequence[index] = sequence[index - 1] + sequence[index - 2];
}
return sequence;
}, token));
}
if (rnd.Next(0, 2) == 1)
source.Cancel();
try {
Task.WaitAll(tasks.ToArray());
foreach (var t in tasks)
Console.WriteLine("{0}, {1}...{2:N0}", t.Result[0], t.Result[1],
t.Result[99]);
}
catch (AggregateException e) {
foreach (var ex in e.InnerExceptions)
Console.WriteLine("{0}: {1}", ex.GetType().Name, ex.Message);
}
}
}
// The example displays either the following output:
// 0, 1...218,922,995,834,555,169,026
// 1, 1...354,224,848,179,261,915,075
// or the following output:
// TaskCanceledException: A task was canceled.
// TaskCanceledException: A task was canceled.
Imports System.Collections.Generic
Imports System.Numerics
Imports System.Threading
Imports System.Threading.Tasks
Module Example
Public Sub Main()
Dim rnd As New Random()
Dim tasks As New List(Of Task(Of BigInteger()))
Dim source As New CancellationTokenSource
Dim token As CancellationToken = source.Token
For ctr As Integer = 0 To 1
Dim start As Integer = ctr
tasks.Add(Task.Run(Function()
Dim sequence(99) As BigInteger
sequence(0) = start
sequence(1) = 1
For index As Integer = 2 To sequence.GetUpperBound(0)
token.ThrowIfCancellationRequested()
sequence(index) = sequence(index - 1) + sequence(index - 2)
Next
Return sequence
End Function, token))
Next
If rnd.Next(0, 2) = 1 Then source.Cancel
Try
Task.WaitAll(tasks.ToArray())
For Each t In tasks
Console.WriteLine("{0}, {1}...{2:N0}", t.Result(0), t.Result(1),
t.Result(99))
Next
Catch e As AggregateException
For Each ex In e.InnerExceptions
Console.WriteLine("{0}: {1}", ex.GetType().Name, ex.Message)
Next
End Try
End Sub
End Module
' The example displays either the following output:
' 0, 1...218,922,995,834,555,169,026
' 1, 1...354,224,848,179,261,915,075
' or the following output:
' TaskCanceledException: A task was canceled.
' TaskCanceledException: A task was canceled.
注解
调用 StartNew 在功能上等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划执行。
从 .NET Framework 4.5 开始,可以使用Task.Run<TResult>(Func<TResult>, CancellationToken)该方法快速调用StartNew<TResult>(Func<TResult>, CancellationToken)默认参数。 但是,请注意,这两种方法在行为上存在差异: Task.Run<TResult>(Func<TResult>, CancellationToken) 默认情况下,不允许从选项开始 TaskCreationOptions.AttachedToParent 的子任务附加到当前 Task<TResult> 实例,而 StartNew<TResult>(Func<TResult>, CancellationToken) 不允许子任务。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<TResult>, TaskCreationOptions)
为指定的函数委托和创建选项创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<TResult> ^ function, System::Threading::Tasks::TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<TResult> function, System.Threading.Tasks.TaskCreationOptions creationOptions);
member this.StartNew : Func<'Result> * System.Threading.Tasks.TaskCreationOptions -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of TResult), creationOptions As TaskCreationOptions) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- function
- Func<TResult>
一个函数委托,可返回能够通过任务获得的将来结果。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
返回
已启动的任务。
例外
function
上声明的默认值为 null
。
creationOptions
指定了一个无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<Object,TResult>, Object, CancellationToken)
为指定的函数委托、状态和取消标记创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<System::Object ^, TResult> ^ function, System::Object ^ state, System::Threading::CancellationToken cancellationToken);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object,TResult> function, object state, System.Threading.CancellationToken cancellationToken);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object?,TResult> function, object? state, System.Threading.CancellationToken cancellationToken);
member this.StartNew : Func<obj, 'Result> * obj * System.Threading.CancellationToken -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of Object, TResult), state As Object, cancellationToken As CancellationToken) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- state
- Object
一个包含由 function
委托使用的数据的对象。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
返回
已启动的任务。
例外
function
上声明的默认值为 null
。
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<Object,TResult>, Object, TaskCreationOptions)
为指定的函数委托、状态和创建选项创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<System::Object ^, TResult> ^ function, System::Object ^ state, System::Threading::Tasks::TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object,TResult> function, object state, System.Threading.Tasks.TaskCreationOptions creationOptions);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object?,TResult> function, object? state, System.Threading.Tasks.TaskCreationOptions creationOptions);
member this.StartNew : Func<obj, 'Result> * obj * System.Threading.Tasks.TaskCreationOptions -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of Object, TResult), state As Object, creationOptions As TaskCreationOptions) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- state
- Object
一个包含由 function
委托使用的数据的对象。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
返回
已启动的任务。
例外
function
上声明的默认值为 null
。
creationOptions
指定了一个无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。
另请参阅
适用于
StartNew<TResult>(Func<Object,TResult>, Object, CancellationToken, TaskCreationOptions, TaskScheduler)
为指定的函数委托、状态、取消标记、创建选项和任务计划程序创建并启动 TResult
类型的任务。
public:
generic <typename TResult>
System::Threading::Tasks::Task<TResult> ^ StartNew(Func<System::Object ^, TResult> ^ function, System::Object ^ state, System::Threading::CancellationToken cancellationToken, System::Threading::Tasks::TaskCreationOptions creationOptions, System::Threading::Tasks::TaskScheduler ^ scheduler);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object,TResult> function, object state, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
public System.Threading.Tasks.Task<TResult> StartNew<TResult> (Func<object?,TResult> function, object? state, System.Threading.CancellationToken cancellationToken, System.Threading.Tasks.TaskCreationOptions creationOptions, System.Threading.Tasks.TaskScheduler scheduler);
member this.StartNew : Func<obj, 'Result> * obj * System.Threading.CancellationToken * System.Threading.Tasks.TaskCreationOptions * System.Threading.Tasks.TaskScheduler -> System.Threading.Tasks.Task<'Result>
Public Function StartNew(Of TResult) (function As Func(Of Object, TResult), state As Object, cancellationToken As CancellationToken, creationOptions As TaskCreationOptions, scheduler As TaskScheduler) As Task(Of TResult)
类型参数
- TResult
可通过任务获取的结果的类型。
参数
- state
- Object
一个包含由 function
委托使用的数据的对象。
- cancellationToken
- CancellationToken
将指派给新的任务的取消标记。
- creationOptions
- TaskCreationOptions
控制所创建的任务的行为的枚举值之一。
- scheduler
- TaskScheduler
用于计划所创建的任务的任务计划程序。
返回
已启动的任务。
例外
creationOptions
指定了一个无效的 TaskCreationOptions 值。 有关更多信息,请参见 FromAsync(Func<AsyncCallback,Object,IAsyncResult>, Action<IAsyncResult>, Object, TaskCreationOptions) 的备注
注解
调用 StartNew 的功能等效于使用其构造函数之一 Task<TResult> 创建,然后调用 Start 以计划其执行。
从 .NET Framework 4.5 开始,可以将Run该方法与Action对象配合使用,以快速方式使用默认参数进行调用StartNew。 有关详细信息和代码示例,请参阅使用 .NET 并行编程的条目 Task.Run 与 Task.Factory.StartNew 。