Task.Run 和 Task.Factory.StartNew

.Net 4中,Task.Factory.StartNew是启动一个新Task的首选方法。它有很多重载方法,使它在具体使用当中可以非常灵活,通过设置可选参数,可以传递任意状态,取消任务继续执行,甚至控制任务的调度行为。所有这些能力也带来了复杂性的提升,你必须知道何时应该使用何种重载方法,提供哪种调度方式等等。并且Task.Factory.StartNew这种写法也不够简洁明快,至少对它使用的主要场景不够快,一般它使用的主要场景只是将一个工作任务丢给一个后台线程执行而已。

于是,在.NET Framework 4.5开发者预览版中,微软引进了新的Task.Run方法。新方法不是为了替代旧的Task.Factory.StartNew方法,只是提供了一种使用Task.Factory.StartNew方法的更简洁的形式,而不需要去指定那一系列参数。这是一个捷径,事实上,Task.Run的内部实现逻辑跟Task.Factory.StartNew一样,只是传递了一些默认参数。比如当你使用Task.Run

Task.Run(someAction);

实际上等价于:

Task.Factory.StartNew(someAction, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

使用这些默认参数,Task.Run就能用于大多数情况——只是将任务简单的交给后台线程池去执行(这也是使用TaskScheduler.Default参数的目标)。这也并不意味着Task.Factory.StartNew方法就不必再使用了,它仍然有很多重要的用处。你可以通过控制TaskCreationOptions参数来控制任务的行为,你也可以通过控制TaskScheduler来控制任务应该如何排队如何运行,你也可以使用重载方法中的接受对象状态那个参数,对于一些性能敏感的代码,它可以用于避免闭包以及相应的资源分配。不过对于上面那个简单的例子,Task.Run是最友好。

Task.Run提供了八种重载方式,用于提供下面这几种组合情况:

  1. 普通任务(Task)和带返回值任务(Task<TResult>
  2. 可取消任务(Cancelable)和不可取消任务(non-cancelabl
  3. 同步委托(Synchronous)和异步委托(Asynchronous

前两个很明显,对于第一点如果是用的Task做返回值的重载方法,那么该任务就没有返回值,如果是用的Task<TResult>做返回值的重载方法,那么该任务就有一个类型为TResult的返回值。对于第二点,也有接受CancellationToken参数的重载,可以在任务开始之前执行取消操作,然后并行任务(Task Parallel Library——TPL)就可以自然的过度到取消状态。
第三点要更有趣一些,它直接关系到Visual studio 11中的C#和Visual Basic的异步语言支持。我们先使用Task.Factory.StartNew来展示下这个问题,如果有下面一段代码:

var t = Task.Factory.StartNew(() =>
{
    Task inner = Task.Factory.StartNew(() => {});
    return inner;
});

这里t的类型会被推断为Task<Task>,因为此处任务的委托类型是Func<TResult>,所以这里TResult的类型就是Task,于是StartNew方法就返回Task<Task>,类似的,我可以改变成下面这种写法:

var t = Task.Factory.StartNew(() =>
{
    Task<int> inner = Task.Factory.StartNew(() => 42));
    return inner;
});

此处的t的类型自然是Task<Task<int>>,任务的委托类型还是Func<TResult>TResult的类型就是Task<int>StartNew方法就返回Task<Task<int>>。这有什么关系呢?考虑下如果我们现在使用下面这种写法:

var t = Task.Factory.StartNew(async delegate
{
    await Task.Delay(1000);
    return 42;
});

这里使用了async关键词,编译器会将这个委托映射成Func<Task<int>>,调用这个委托最终会返回Task<int>。因为这个这个委托是Func<Task<int>>TResult的类型就是Task<int>,所以最后t的类型应该是Task<Task<int>>,而不是Task<int>

为了应对这几种情况,在.Net 4中引入了Unwrap方法。Unwrap方法有两种重载形式,均是扩展方法的形式,一种是针对类型Task<Task>,另一种是针对<Task<TResult>>。微软只所以要把这个方法命名为解包(Unwrap),是因为这个方法可以返回任务的实际结果。对Task<Task>调用Unwrap方法可以返回一个新的Task(就像内部任务的一个代理一样)代表它的内部任务。相似的,对Task<Task<TResult>>调用Unwrap返回一个新的Task<TResult>代表它的内部任务。但是,如果外部任务失败了或者取消了,就不会有内部任务了,因为没有任务运行完成,所以代理任务也就变成了外部任务的状态。回到前面的例子,如果想让t代表内部任务的返回值(在这个例子中,这个值是42),那么应该像下面这样写:

var t = Task.Factory.StartNew(async delegate
{
    await Task.Delay(1000);
    return 42;
}).Unwrap();

现在,变量t的类型是Task<int>,代表异步调用的结果。

现在回到Task.Run,因为微软想让开发者尽可能的使用这个方法来启用后台任务,并且可以配合async/await使用,所以微软决定在Task.Run方法中内建unwrapping的功能。这也是上面第三点所指的内容,Task.Run的重载方法中有可以接受Action(没有返回值的任务)的,有接受Func<TResult>(返回TResult的任务)的,有接受Func<Task>(返回一个异步任务的任务)的,还有接受Func<Task<TResult>>(返回一个带TResult类型返回值的异步任务的任务)的。总的来说,Task.Run方法提供了上面Task.Factory.StartNew方法相同的unwrapping操作。于是,我们可以这样写:

var t = Task.Run(async delegate
{
    await Task.Delay(1000);
    return 42;
});

t的类型是Task<int>,此处Task.Run执行的重载方法等价于:

var t = Task.Factory.StartNew(async delegate
{
    await Task.Delay(1000);
    return 42;
}, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default).Unwrap();

如前所述,这是一个快捷方式。

上面讲的全部类容都意味着你可以使用Task.Run调用标准的lambdas/anonymous方法或是异步lambdas/anonymous方法,最后总会按你所期望的行为运行。如果我们想让任务在后台运行并且想等待它的结果,那么可以像下面这样写:

int result = await Task.Run(async () =>
{
    await Task.Delay(1000);
    return 42;
});

此处变量result的类型正是你所期望的int,并且在该任务被调用大约1秒钟后,变量result的值被设置为42。

有趣的是,新的await关键字被认为是等价于Unwrap方法的一种新语法形式。于是,如果我们回到上面那个Task.Factory.StartNew例子,我们可以先用Unwrap重写上面那个代码片段:

int result = await Task.Factory.StartNew(async delegate
{
    await Task.Delay(1000);
    return 42;
}, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default).Unwrap();

或者,可以使用第二个await替换Unwrap

int result = await await Task.Factory.StartNew(async delegate
{
    await Task.Delay(1000);
    return 42;
}, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

这里的await await虽然看着别扭,但是并没有问题。Task.Factory.StartNew方法返回一个Task<Task<int>>,对Task<Task<int>>使用await实际上返回Task<int>,然后再对Task<int>使用await最后返回int,难道不是这样吗?

时间: 2024-10-12 04:56:02

Task.Run 和 Task.Factory.StartNew的相关文章

Task.Run vs Task.Factory.StartNew

Task.Run 和 Task.Factory.StartNew 都可以把一段要执行的代码放到ThreadPool thread中去执行.Task.Factory.StartNew是.Net 4.0中引入的,而Task.Run则是在.Net 4.5中引入,首要目的是为了简化Task.Factory.StartNew的使用.简言之, Task.Run(someAction) 与 Task.Factory.StartNew(someAction, CancellationToken.None, Ta

Task.Run 和Task.Factory.StartNew 区别

.Net Framework 4.0开始支持Task.Factory.StartNew,.Net Framework 4.5后开始支持Task.Run. Task.Factory.StartNew经过简化成了Task.Run,注意的是Factory.StartNew的方法参数种类更丰富,可以完成多样的需求. 在选择上,如果创建的线程需要长时间运行的话那就选择Task.Factory.StartNew. 一:使用 Task.Run(() =>{......}); Task.Factory.Star

Task.Run 和 Task.Factory.StartNew 区别

Task.Run 是在 dotnet framework 4.5 之后才可以使用, Task.Factory.StartNew 可以使用比 Task.Run 更多的参数,可以做到更多的定制. 可以认为 Task.Run 是简化的 Task.Factory.StartNew 的使用,除了需要指定一个线程是长时间占用的,否则就使用 Task.Run 创建新线程 下面来告诉大家使用两个函数创建新的线程 Task.Run(() => { var foo = 2; }); 这时 foo 的创建就在另一个线

.Net4.0如何实现.NET4.5中的Task.Run及Task.Delay方法

前言 .NET4.0下是没有Task.Run及Task.Delay方法的,而.NET4.5已经实现,对于还在使用.NET4.0的同学来说,如何在.NET4.0下实现这两个方法呢? 在.NET4.0下,有一个泛型类,叫TaskCompletionSource<TReuslt>,它能控制Task的行为,如给Task设置结果.设置异常.设置取消等. MSDN是这样描述的(网址): 表示未绑定到委托的 Task<TResult> 的制造者方,并通过Task属性提供对使用者方的访问. 它有以

Task.Factory.StartNew 和 Task.Run

项目中可能经常用到异步和线程,为了不影响主线程而新开一个线程去操作其他逻辑,那么Task 经常被人用到. 本人在一个工程中搜索后发现,主要有如下俩中用法: Task.Factory.StartNew(() => { }); Task.Run(() => { }); 应用场景都是一样的,为啥有俩中写法, 那么他的联系和区别有什么呢? 1)网上说: Task.Factory.StartNew和Task.Run区别之一就有Task.Run会自动执行Unwrap操作,但是Task.Factory.St

C# Task,new Task().Start(),Task.Run();TTask.Factory.StartNew

1. Task task = new Task(() => { MultiplyMethod(a, b); }); task.Start(); 2. Task task = Task.Run(() => { MultiplyMethod(a, b); }); 3. Task task = Task.Factory.StartNew(() => { MultiplyMethod(a, b); });

Task.Factory.StartNew 测试

到底该用多少线程?线程数.CPU核心数.本地计算时间.等待时间的关系 线程数 = CPU核心数 * ( 本地计算时间 + 等待时间 ) / 本地计算时间 下面是Task.Factory.StartNew和自己写的TaskHelper.LargeTask.Run对比测试 一.Task.Factory.StartNew 使用 TaskCreationOptions.LongRunning 参数 代码: private int n = 50000; //问题规模 private int t = 25;

MVC4 Task.Factory.StartNew 异步调用

MVC4也添加了一些异步的东西,不过一枝都没有研究过. 工作上遇到了发出一个调用,但是不去管调用结果如何的情况,在谢平师傅的指导下, 写成如下异步方式 Task.Factory.StartNew(() => { if (entity.IsManager == true) { bool resultSetOnlineReportOn = ReportOnlineProxy.SaveUIDPermissions(entity.Uid, true); } else { bool resultSetOn

Task.Factory.StartNew的用法

代码: private void button5_Click(object sender, EventArgs e) { int val = 5; Task.Factory.StartNew(() => { MessageBox.Show("测试StartNew:无参数"); }); Task.Factory.StartNew(a => { MessageBox.Show("测试StartNew:参数值" + (int)a); }, val); }