草庐IT

C# 探秘如何优雅的终止线程

老码识途 2023-03-28 原文

在刚接触后台线程的时候,觉得线程神秘且高深,并且时常有先辈们千叮万嘱:能不用的时候,尽量不要用,千万不要滥用线程,否则会发生预料不到的结果。在接触线程一段时间后,感觉线程也不过如此,轻而易举的就可以创建,所以逐渐大胆起来,项目里随处可见的都是Task,Thread,async,await等内容。在大多情况下,我们只关心线程的创建与启动,运行,却并不关心线程的结束或者终止。今天这篇文章,我们就以一些简单的小例子,简述如何有效的停止线程,仅供学习分享使用,如有不足之处,还请指正。

 

 

需求说明

现在有一个需求:有一个后台线程,定时(300ms)输出一段内容,但不希望它一直运行,所以设置了超时时间(3s),希望在超时结束后,便执行后续的内容。

初始版本

根据需求,开发了第一个版本的代码,步骤如下:

  1. 定义一个Task。
  2. 在Task内,运行死循环,每间隔300毫秒,输出一段内容。
  3. 设置Task的等待超时时间,超时结束后,运行后续内容。

具体代码如下所示:

 1 namespace DemoTask
 2 {
 3     internal class Program
 4     {
 5         static void Main(string[] args)
 6         {
 7             TestTask();
 8             Console.ReadKey();
 9         }
10 
11         /// <summary>
12         /// 测试任务
13         /// </summary>
14         public static void TestTask()
15         {
16             Console.WriteLine("程序开始.");
17             var task = Task.Run(() =>
18             {
19                 while (true)
20                 {
21                     Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
22                     Thread.Sleep(300);
23                 }
24             });
25             task.Wait(3000);
26             Console.WriteLine("程序超时结束.");
27         }
28     }
29 }

信心满满的运行程序,但是期待的结果并没有出现,在超时时间后,并没有预期的停止任务,反而在继续运行。如下所示:

注意:通过以上程序发现,Wait方法只是等待时间结束后不再等待,但是原有任务并未结束,而是继续运行。

进阶版本

为了解决线程无法结束的问题,微软官方给出的方案是采用CancellationTokenSource,向应该被取消的线程发送信号。即在线程内部判断是否收到取消请求,在外部发起取消请求信号。步骤如下:

  1. 定义一个Task。
  2. 在Task内,当没有收到取消信号时,每间隔300毫秒,输出一段内容。
  3. 设置Task的等待超时时间,超时结束后,发起取消信号,并运行后续内容。

具体代码如下所示:

 1 /// <summary>
 2 /// 测试任务
 3 /// </summary>
 4 public static void TestTask()
 5 {
 6     Console.WriteLine("程序开始.");
 7     CancellationTokenSource cts = new CancellationTokenSource();
 8     CancellationToken token = cts.Token;
 9     var task = Task.Run(() =>
10     {
11         while (!token.IsCancellationRequested)
12         {
13             Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
14             Thread.Sleep(300);
15         }
16     });
17     bool flag = task.Wait(3000);
18     if (!flag) { 
19         cts.Cancel();
20     }
21     Console.WriteLine("程序超时结束.");
22 }

优化程序后,运行程序如下所示:

注意:经过以上程序优化后,确实是如预想的结果一致,程序在等待超时时间后,停止了运行。

最终版本

正常情况下,如果是我们自己开发的程序,程序到第二个版本就已经解决问题了,但是假如While循环的内容是第三方提供的程序,已经封装为固定模块,我们无法进行修改,那应该如何才能终止死循环呢?如何才能像任务管理器结束进程一样,结束这一直无休止运行的程序呢?

为了解决我们的难题,对程序进行进一步的优化,步骤如下:

  1. 定义一个Task。
  2. 在Task内,注册线程的Abort方法,在未调用Abort方法时,每间隔300毫秒,输出一段内容。
  3. 设置Task的等待超时时间,超时结束后,发起取消信号,并运行后续内容。

具体代码如下所示:

 1 /// <summary>
 2 /// 测试任务
 3 /// </summary>
 4 public static void TestTask()
 5 {
 6     Console.WriteLine("程序开始.");
 7     CancellationTokenSource cts = new CancellationTokenSource();
 8     CancellationToken token = cts.Token;
 9     var task = Task.Run(() =>
10     {
11         using (token.Register((Thread.CurrentThread.Abort)))
12         {
13             //假设以下内容第3方提供,无法修改
14             while (true)
15             {
16                 Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
17                 Thread.Sleep(300);
18             }
19             //以上内容第3方提供
20         }
21     });
22     bool flag = task.Wait(3000);
23     if (!flag)
24     {
25         cts.Cancel();
26     }
27     Console.WriteLine("程序超时结束.");
28 }

优化程序后,运行程序如下所示:

另外一种写法

经过小伙伴反馈,Thread.CurrentThread.Abort在.Net5及以上版本,已经过时,会报PlatformNotSupportedException错误,捕获后,任务也没有停止,经过调试,可以将Thread.CurrentThread.Abort改为Thread.CurrentThread.Interrupt。如下所示:

 1 /// <summary>
 2 /// 测试任务
 3 /// </summary>
 4 public static void TestTask()
 5 {
 6     Console.WriteLine("程序开始.");
 7     CancellationTokenSource cts = new CancellationTokenSource();
 8     CancellationToken token = cts.Token;
 9     var task = Task.Run(() =>
10     {
11         try
12         {
13             using (token.Register(Thread.CurrentThread.Interrupt))
14             {
15 
16                 //假设以下内容第3方提供,无法修改
17                 while (true)
18                 {
19 
20                     Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
21                     Thread.Sleep(300);
22                 }
23                 //以上内容第3方提供
24             }
25         }
26         catch (Exception ex) { 
27         
28         }
29     });
30     bool flag = task.Wait(300);
31     if (!flag)
32     {
33         try
34         {
35             cts.Cancel();
36         }
37         catch (Exception ex)
38         {
39 
40         }
41     }
42     Console.WriteLine("程序超时结束.");
43 }

以上就是我们对后台服务线程的终止问题的探索,解决问题的方式还有很多,希望本篇文章可以抛砖引玉,一起学习,共同进步。

有关C# 探秘如何优雅的终止线程的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

    总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  3. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  4. ruby-on-rails - 如何验证 update_all 是否实际在 Rails 中更新 - 2

    给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息? 最佳答案 在Rails3中,update_all不返回任何有意义的信息,除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru

  5. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗?当我运行compasswatch时,它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行?文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们?我自己编译的.sass文件编译成compiled/t

  6. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  7. ruby - 如何指定 Rack 处理程序 - 2

    Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时,rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack

  8. ruby - 如何每月在 Heroku 运行一次 Scheduler 插件? - 2

    在选择我想要运行操作的频率时,唯一的选项是“每天”、“每小时”和“每10分钟”。谢谢!我想为我的Rails3.1应用程序运行调度程序。 最佳答案 这不是一个优雅的解决方案,但您可以安排它每天运行,并在实际开始工作之前检查日期是否为当月的第一天。 关于ruby-如何每月在Heroku运行一次Scheduler插件?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/8692687/

  9. ruby-on-rails - 如何从 format.xml 中删除 <hash></hash> - 2

    我有一个对象has_many应呈现为xml的子对象。这不是问题。我的问题是我创建了一个Hash包含此数据,就像解析器需要它一样。但是rails自动将整个文件包含在.........我需要摆脱type="array"和我该如何处理?我没有在文档中找到任何内容。 最佳答案 我遇到了同样的问题;这是我的XML:我在用这个:entries.to_xml将散列数据转换为XML,但这会将条目的数据包装到中所以我修改了:entries.to_xml(root:"Contacts")但这仍然将转换后的XML包装在“联系人”中,将我的XML代码修改为

  10. ruby - 如何使用文字标量样式在 YAML 中转储字符串? - 2

    我有一大串格式化数据(例如JSON),我想使用Psychinruby​​同时保留格式转储到YAML。基本上,我希望JSON使用literalstyle出现在YAML中:---json:|{"page":1,"results":["item","another"],"total_pages":0}但是,当我使用YAML.dump时,它不使用文字样式。我得到这样的东西:---json:!"{\n\"page\":1,\n\"results\":[\n\"item\",\"another\"\n],\n\"total_pages\":0\n}\n"我如何告诉Psych以想要的样式转储标量?解

随机推荐