2

这样在 C# 使用 LongRunnigTask 是错的 - Newbe36524

 1 year ago
source link: https://www.cnblogs.com/newbe36524/p/0x026-This-is-the-wrong-way-to-use-LongRunnigTask-in-csharp.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

Task.Factory.StartNew 有一个重载,是支持 TaskCreationOptions.LongRunning 参数来指定 Task 的特征的。但是可能在没有注意的情况下,你就使用了错误的用法。那么本文我们来简单阐述一下这个参数的作用,和使用的注意要点。

这样其实是错误的

有的时候,你可能会这么写:

Task.Factory.StartNew(async () =>{ while (true) { // do something await Task.Delay(1000); }}, TaskCreationOptions.LongRunning);

但其实,这是个错误的写法。

为什么需要 LongRunning

我们通常两种情况下会想到使用 TaskCreationOptions.LongRunning 参数:

  1. 你的任务需要长时间运行,比如一个循环,或者一个死循环。用来从队列中取数据,然后处理数据,或者是一些定时任务。
  2. 你的任务需要占用大量的 CPU 资源,是一个很大的循环,比如要遍历一个很大的数组,并做一些处理。

那么这个时候,我们就需要使用 TaskCreationOptions.LongRunning 参数来指定 Task。

因为我们可能学习到了,Task 默认的 Scheduler 是 ThreadPool,而 ThreadPool 的线程是有限的,如果你的任务需要长时间运行,或者是需要占用大量的 CPU 资源,那么就会导致 ThreadPool 的线程不够用。导致线程饥饿,或者是线程池的线程被占用,导致其他的任务无法执行。

于是我们很聪明的就想到了,我们可以使用 TaskCreationOptions.LongRunning 参数来指定 Task,这样就可以避免线程饥饿。

但是实际上,开篇的写法并不能达到我们的目的。

我们可以通过以下代码来验证一下:

var task = Task.Factory.StartNew(async () =>{ while (true) { // do something await Task.Delay(1000); }}, TaskCreationOptions.LongRunning); Thread.Sleep(3000); Console.WriteLine($"Task Status: {task.Status}");// Task Status: RanToCompletion

我们可以看到,Task 的状态是并非是 Running,而是 RanToCompletion。

也就是说,我们的任务在 3 秒后就已经执行完了,而不是我们想要的长时间运行。

究其原因,是因为我们采用了异步的方式来执行任务。而异步任务的执行,是通过 ThreadPool 来执行的。也就是说,虽然我们使用了 TaskCreationOptions.LongRunning 参数,来想办法指定线程池单独开一个线程,但是实际上在一个 await 之后,我们的任务还是在 ThreadPool 中执行的。

这会导致,我们的任务实际上后续又回到了 ThreadPool 中,而不是我们想要的单独的线程。起不到单独长期运行的作用。

正确的写法

因此,实际上如果想要保持单独的线程持续的运行,我们需要移除异步的方式,改为同步的方式。

var task = Task.Factory.StartNew(() =>{ while (true) { // do something Thread.Sleep(1000); }}, TaskCreationOptions.LongRunning); Thread.Sleep(3000); Console.WriteLine($"Task Status: {task.Status}");// Task Status: Running

这样我们就可以看到,Task 的状态是 Running,而不是 RanToCompletion。我们通过 TaskCreationOptions.LongRunning 参数,单独开启的线程就可以一直运行下去。

实际上还有很多考量

要考量 TaskScheduler 的实现

本文采用的是 aspnetcore 的实现,但是在其他的实现中,可能会有不同的实现。你也完全有可能实现一个 await 之后,不回到 ThreadPool 的实现。

LongRunning 也不是就不能用异步

正如开篇提到的第二种场景,如果你的业务是在第一个 await 之前有大量的同步代码,那么此时单独开启一个线程,也是有意义的。

我就是一个死循环,里面也是异步的怎么办

那么你可以考虑让这个 LongRuning 的 Task,不要 await,而是通过 Wait() 来等待。这样就可以避免 LongRunning 的 Task 直接结束。

本文我们简单阐述了 TaskCreationOptions.LongRunning 参数的作用,和使用的注意要点。

感谢阅读,如果觉得本文有用,不妨点击推荐👍或者在评论区留下 Mark,让更多的人可以看到。

欢迎关注作者的微信公众号“newbe技术专栏”,获取更多技术内容。 关注微信公众号“newbe技术专栏”


  1. https://www.cnblogs.com/eventhorizon/p/15912383.html

  2. https://threads.whuanle.cn/3.task/

  3. https://learn.microsoft.com/en-us/dotnet/api/system.threading.tasks.taskcreationoptions?view=net-7.0&WT.mc_id=DX-MVP-5003606


Recommend

  • 4
    • wangwei1237.github.io 2 years ago
    • Cache

    为什么 OpenCV 计算的视频 FPS 是错的

    我们有一个平台来周期性的对线上的直播流数据进行某些检测,例如黑/白屏检测、静态画面检测……在检测中,我们会根据提取到的直播流的帧率来预...

  • 2

    通过 CancellationToken 提高 Web 性能 在 Web 开发...

  • 6

    如何使用 IdGen 生成 UID 在分布式系统中,雪花 ID...

  • 8

    我们之前提到 List 是 .NET 中常用的数据结构,其在存储大量数据时,如果能够指定它的初始化容量,就会有性能提升。这个优化的方法并不是很明显,因此本文将使用 BenchmarkDotNet 库,通过定量对比的方式来证明这一点。 引入 BenchmarkDotNet 首先...

  • 8

    在 .Net 7 中,我们可以通过绑定数组的方式来接收来自查询字符串的参数。这样就不需要再使用逗号分隔的字符串来获取参数了。 假设我们需要从 query 上接受多个 id 并返回查询的结果。例如: id=1&id=2 在 .Net 7 中,我们可以这样实现:

  • 3

    有的时候你有多个应用程序,它们需要使用相同的日志配置。在这种情况下,你可以将日志配置放在一个共享的位置,然后通过项目文件快速引用。方便快捷,不用重复配置。 Directory.Build.props 通过在项目文件夹中创建一个名为 Directory.Build....

  • 5

    在 C# 9 中使用 foreach 扩展 在 C# 9 中,foreach...

  • 3
    • www.cnblogs.com 1 year ago
    • Cache

    如何使用 ArrayPool - Newbe36524

    如果不停的 new 数组,可能会造成 GC 的压力,因此在 aspnetcore 中推荐使用 ArrayPool 来重用数组,本文将介绍如何使用 ArrayPool。 使用 ArrayPool ArrayPool 是一个静态类,它提供了一个共享的数组池,可以用来重用数组。它可以用来避免频繁的分...

  • 5

    在 .net 7 以前,项目对于 nuget 依赖项的版本依赖散落与解决方案的各个角落。这导致升级维护和查看的时候都比较麻烦。在 .net 7 中,你可以使用一个文件来集中管理你的 Nuget 依赖版本号。本篇文章将介绍如何使用这个功能。 为什么需要这个功能 通...

  • 2

    这样在 C# 使用 LongRunnigTask 是错的 2023-03-05 4Task.Factory.StartNew 有一个重载,是支持 TaskCreationOptions.LongRunning 参数来指定 Task 的特征的。但是可能在没有注意的情况下,你就使...

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK