我已经实现了一个简单的 Task.Factory.StartNew()，但我想知道如何改用 Task.Run() 来实现它？
以下是基本代码：
Task.Factory.StartNew(new Action<object>(
(x) =>
{
// Do something with 'x'
}), rawData);
我在对象浏览器中查看了System.Threading.Tasks.Task，但是我找不到类似于Action<T>的参数。只有接受void参数且没有类型的Action。
只有两个类似的东西：static Task Run(Action action)和static Task Run(Func<Task> function)，但都不能使用参数。
是的，我知道我可以为此创建一个简单的扩展方法，但我的主要问题是能否在单行中使用Task.Run()编写它？
private void RunAsync()
{
//Beware of closures. String is immutable.
string param = "Hi";
Task.Run(() => MethodWithParameter(param));
}
private void MethodWithParameter(string param)
{
//Do stuff
}
编辑
由于大家的需求，我必须注意到启动的Task将与调用线程并行运行。假设使用默认的TaskScheduler，这将使用.NET ThreadPool。无论如何，这意味着您需要考虑传递给Task的任何参数可能同时被多个线程访问，并使它们成为共享状态。这包括在调用线程上访问它们。
在上面的代码中，这种情况是完全无关紧要的。字符串是不可变的。这就是为什么我把它们作为例子使用的原因。但是，假设您没有使用String...
一个解决方案是使用async和await。这默认情况下将捕获调用线程的SynchronizationContext，并将在对await的调用之后为方法的其余部分创建一个延续并将其附加到创建的Task。如果此方法在WinForms GUI线程上运行，则其类型将为WindowsFormsSynchronizationContext。
延续将在被发送回捕获的SynchronizationContext后运行——同样仅限默认情况下。因此，在await调用之后，您将回到开始的线程上。您可以以各种方式更改这一点，特别是使用ConfigureAwait。简而言之，该方法的其余部分将在Task在另一个线程上完成之后才会继续运行。但是，调用线程将继续并行运行，只有该方法的其余部分不会。
该方法等待完成其余部分可能是可取的，也可能不是。如果该方法中没有后来访问传递给Task的参数，您可能根本不想使用await。
或者，您稍后在方法中使用这些参数。没有理由立即使用await，因为您可以安全地继续执行工作。请记住，您可以将返回的Task存储在变量中，并稍后在同一方法中await它——甚至在需要在执行一些其他工作后安全访问传递的参数时。再次强调，您不需要在运行Task时立即使用await。
无论如何，使传递给Task.Run的参数在线程安全方面变得简单的方法是这样做：
您必须首先使用async修饰RunAsync：
private async void RunAsync()
重要提示
如链接文档所述，最好使用标记为async的方法不应该返回 void。常见的例外是事件处理程序（如按钮点击等），它们必须返回 void。否则，我总是尝试在使用 async 时返回 Task 或 Task<TResult>。这是一个很好的实践，有很多原因。
现在，您可以像下面这样await运行Task。您不能在没有async的情况下使用await。
await Task.Run(() => MethodWithParameter(param));
//Code here and below in the same method will not run until AFTER the above task has completed in one fashion or another
总的来说，如果您使用 await 等待任务，则可以避免将传入参数视为可能共享资源的情况，并避免多个线程同时修改某些内容的所有陷阱。此外，请注意闭包。我不会深入介绍它们，但链接的文章做得非常好。
关于 Run 和 StartNew ，下面的代码是我认为最重要的要知道的。有合法的理由可选择其中任一种，两者都不过时或比另一种更好。只有在了解以下内容时，才能简单地用一个替换另一个：
//These are exactly the same
Task.Run(x);
Task.Factory.StartNew(x, CancellationToken.None,
TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
//These are also exactly the same
Task.Factory.StartNew(x);
Task.Factory.StartNew(x, CancellationToken.None,
TaskCreationOptions.None, TaskScheduler.Current);
侧记
话题有点偏离，但是由于WinForms GUI线程被标记为[STAThread]，注意不要在此线程上使用任何类型的“阻塞”。使用await完全不会阻塞，但我有时候会看到它与某种形式的阻塞一起使用。
“阻塞”使用引号因为你在技术上不能阻塞WinForms GUI线程。即使在WinForms GUI线程上使用lock，它仍然会传递消息，尽管您认为它已经“阻塞”了。它没有。
这可能会在非常罕见的情况下导致奇怪的问题。例如，其中一个原因是你永远不想在绘图时使用lock。但那是一个边缘和复杂的案例；但我曾看到它引起疯狂的问题。所以我为了完整起见而指出了它。
Task.Run(() => MethodWithParameter(param));。这意味着，如果 param 在 Task.Run 之后被修改，那么在 MethodWithParameter 中可能会得到意外的结果。 - Alexandre Severino使用变量捕获来“传递”参数。
var x = rawData;
Task.Run(() =>
{
// Do something with 'x'
});
您也可以直接使用rawData，但必须小心。如果您在任务之外更改rawData的值（例如，在for循环中的迭代器中），它也会更改任务内部的值。
从现在开始，您也可以：
Action<int> action = (o) => Thread.Sleep(o);
int param = 10;
await new TaskFactory().StartNew(action, param)
IDisposable对象传递到任务委托以解决ReSharper警告“在外部范围中处置捕获的变量”的问题，则可以很好地完成这项工作。与流行观点相反，在需要传递状态的情况下，使用Task.Factory.StartNew而不是Task.Run没有任何问题。请参见这里。 - NeoStartNew需要Action<object>作为参数... - Kirsan我知道这是一个旧帖子，但我想分享一下我的解决方案，因为被接受的帖子仍然存在问题。
问题：
如Alexandre Severino所指出的，如果param（在下面的函数中）在函数调用后不久发生变化，则可能会在MethodWithParameter中得到一些意外行为。
Task.Run(() => MethodWithParameter(param));
我的解决方案：
为了解决这个问题，我最终编写了以下类似的代码：
(new Func<T, Task>(async (p) => await Task.Run(() => MethodWithParam(p)))).Invoke(param);
param（值类型）会传递其值，因此即使异步方法在param更改后运行，p将具有param在此代码行运行时的任何值。var localParam = param; await Task.Run(() => MethodWithParam(localParam)); - Stephen Cleary只需使用Task.Run。
var task = Task.Run(() =>
{
//this will already share scope with rawData, no need to use a placeholder
});
public Task<T> SomethingAsync<T>()
{
var task = Task.Run(() =>
{
//presumably do something which takes a few ms here
//this will share scope with any passed parameters in the method
return default(T);
});
return task;
}
for(int rawData = 0; rawData < 10; ++rawData) { Task.Run(() => { Console.WriteLine(rawData); } ) }与OP的StartNew示例中传递rawData不会表现相同。 - Scott Chamberlain这个想法是避免使用像上面那样的信号。 将int值注入结构体中可以防止这些值在结构体中发生变化。 我曾经遇到过以下问题：循环变量i在调用DoSomething(i)之前就已经改变了（在循环结束时i被递增，然后()=> DoSomething(i,ii)被调用）。使用结构体后，这种情况不再发生。这是一个非常棘手的错误：DoSomething(i, ii)看起来很好，但永远不确定它是否每次都以不同的i值调用（或只是100次以i=100调用），因此 -> 结构体
struct Job { public int P1; public int P2; }
…
for (int i = 0; i < 100; i++) {
var job = new Job { P1 = i, P2 = i * i}; // structs immutable...
Task.Run(() => DoSomething(job));
}
不清楚原始问题是否与我遇到的问题相同：在循环内计算时希望最大化CPU线程，同时保留迭代器的值并保持内联，以避免向工作函数传递大量变量。
for (int i = 0; i < 300; i++)
{
Task.Run(() => {
var x = ComputeStuff(datavector, i); // value of i was incorrect
var y = ComputeMoreStuff(x);
// ...
});
}
我通过更改外部迭代器并使用一个门来定位其值，使这个工作起来了。
for (int ii = 0; ii < 300; ii++)
{
System.Threading.CountdownEvent handoff = new System.Threading.CountdownEvent(1);
Task.Run(() => {
int i = ii;
handoff.Signal();
var x = ComputeStuff(datavector, i);
var y = ComputeMoreStuff(x);
// ...
});
handoff.Wait();
}
有另一种方法可以做到这一点。我发现它很有用。
int param;
ThreadPool.QueueUserWorkItem(someMethod, param);
void someMethod(object parameter){
var param = (int) parameter;
// do the job
}
rawData是一个网络数据包，它有一个容器类（比如 DataPacket），我正在重用这个实例来减少垃圾回收压力。因此，如果我直接在Task中使用rawData，它可能会在Task处理之前被改变。现在，我认为可以为它创建另一个byte[]实例。我认为这是对我来说最简单的解决方案。 - Thus Spoke NomadAction<byte[]>并不会改变这一点。 - Jon Skeet