详解C#如何优雅地终止线程
作者:小六公子 发布时间:2023-11-21 11:41:31
在刚接触后台线程的时候,觉得线程神秘且高深,并且时常有先辈们千叮万嘱:能不用的时候,尽量不要用,千万不要滥用线程,否则会发生预料不到的结果。在接触线程一段时间后,感觉线程也不过如此,轻而易举的就可以创建,所以逐渐大胆起来,项目里随处可见的都是Task,Thread,async,await等内容。在大多情况下,我们只关心线程的创建与启动,运行,却并不关心线程的结束或者终止。今天这篇文章,我们就以一些简单的小例子,简述如何有效的停止线程,仅供学习分享使用,如有不足之处,还请指正。
需求说明
现在有一个需求:有一个后台线程,定时(300ms)输出一段内容,但不希望它一直运行,所以设置了超时时间(3s),希望在超时结束后,便执行后续的内容。
初始版本
根据需求,开发了第一个版本的代码,步骤如下:
定义一个Task。
在Task内,运行死循环,每间隔300毫秒,输出一段内容。
设置Task的等待超时时间,超时结束后,运行后续内容。
具体代码如下所示:
namespace DemoTask
{
internal class Program
{
static void Main(string[] args)
{
TestTask();
Console.ReadKey();
}
/// <summary>
/// 测试任务
/// </summary>
public static void TestTask()
{
Console.WriteLine("程序开始.");
var task = Task.Run(() =>
{
while (true)
{
Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
Thread.Sleep(300);
}
});
task.Wait(3000);
Console.WriteLine("程序超时结束.");
}
}
}
信心满满的运行程序,但是期待的结果并没有出现,在超时时间后,并没有预期的停止任务,反而在继续运行。如下所示:
注意:通过以上程序发现,Wait方法只是等待时间结束后不再等待,但是原有任务并未结束,而是继续运行。
进阶版本
为了解决线程无法结束的问题,微软官方给出的方案是采用CancellationTokenSource,向应该被取消的线程发送信号。即在线程内部判断是否收到取消请求,在外部发起取消请求信号。步骤如下:
定义一个Task。
在Task内,当没有收到取消信号时,每间隔300毫秒,输出一段内容。
设置Task的等待超时时间,超时结束后,发起取消信号,并运行后续内容。
具体代码如下所示:
/// <summary>
/// 测试任务
/// </summary>
public static void TestTask()
{
Console.WriteLine("程序开始.");
CancellationTokenSource cts = new CancellationTokenSource();
CancellationToken token = cts.Token;
var task = Task.Run(() =>
{
while (!token.IsCancellationRequested)
{
Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
Thread.Sleep(300);
}
});
bool flag = task.Wait(3000);
if (!flag) {
cts.Cancel();
}
Console.WriteLine("程序超时结束.");
}
优化程序后,运行程序如下所示:
注意:经过以上程序优化后,确实是如预想的结果一致,程序在等待超时时间后,停止了运行。
最终版本
正常情况下,如果是我们自己开发的程序,程序到第二个版本就已经解决问题了,但是假如While循环的内容是第三方提供的程序,已经封装为固定模块,我们无法进行修改,那应该如何才能终止死循环呢?如何才能像任务管理器结束进程一样,结束这一直无休止运行的程序呢?
为了解决我们的难题,对程序进行进一步的优化,步骤如下:
定义一个Task。
在Task内,注册线程的Abort方法,在未调用Abort方法时,每间隔300毫秒,输出一段内容。
设置Task的等待超时时间,超时结束后,发起取消信号,并运行后续内容。
具体代码如下所示:
/// <summary>
/// 测试任务
/// </summary>
public static void TestTask()
{
Console.WriteLine("程序开始.");
CancellationTokenSource cts = new CancellationTokenSource();
CancellationToken token = cts.Token;
var task = Task.Run(() =>
{
using (token.Register((Thread.CurrentThread.Abort)))
{
//假设以下内容第3方提供,无法修改
while (true)
{
Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}程序正在运行...");
Thread.Sleep(300);
}
//以上内容第3方提供
}
});
bool flag = task.Wait(3000);
if (!flag)
{
cts.Cancel();
}
Console.WriteLine("程序超时结束.");
}
优化程序后,运行程序如下所示:
来源:https://www.cnblogs.com/hsiang/p/17232227.html


猜你喜欢
- spring的自动装配功能的定义:无须在Spring配置文件中描述javaBean之间的依赖关系(如配置<property>、&
- 1.给定时间戳返回指定的时间格式private string StampToDate(string timeStamp,string for
- 一、修改ReadOnly属性1、设置整个DataGridView只读:DataGridView.ReadOnly=true;此时用户的新增行
- 开发过程中经常遇到需要用某些http://maven.apache.org/中没有的jar包,这个时候可以用maven命令自己添加通常这些j
- 目标依赖<!-- poi工具类--> <dependency>
- 本文实例讲述了C#通过DataSet读写xml文件的方法。分享给大家供大家参考。具体实现方法如下:DataSet ds = new Data
- 最近客户更新系统发现,以前的项目在调用相机的时候,闪退掉了,很奇怪,后来查阅后发现,Android 6.0以后需要程序授权相机权限,默认会给
- 本文实例分析了C#双缓冲技术。分享给大家供大家参考,具体如下:双缓冲解决闪烁问题。整理:GDI+的双缓冲问题一直以来的误区:.net1.1
- 构造方法以及参数:PageView可用于Widget的整屏滑动切换,如当代常用的短视频APP中的上下滑动切换的功能,也可用于横向页面的切换,
- 本文介绍 Spring Boot 项目中整合 ElasticSearch 并实现 CRUD 操作,包括分页、滚动等功能。之前在公司使用 ES
- 前言本文例子实现了点击显示悬浮窗口,同时窗口可播放视频,拖动位置,点击关闭及返回 APP 页面,通过例子来讲述悬浮窗口实现原理及细节处理,效
- 1.循环遍历private void GetControls(Control fatherControl){ Co
- 最近重构了一下我的存档框架。我在这里对实现方法进行简单的解析。注意这里主要演示算法,所以,效率上并不是最佳。一个游戏中,可能有成百上千个物体
- 将一个字符串转化成String[]数组,提供两种方法前言将字符串转化成数组提供两种方法:1.split("");2.to
- private void button1_Click(object sender, EventArgs e) &nbs
- 最近在我参与的几个.Net项目中都有用到异步编程,作为一名.Net小白,很有必要好好地学习一下C#异步编程。什么是异步异步指的就是不用阻塞当
- Java的集合类是一种特别有用的工具,它可以用于存储数量不等的多个对象,并可以实现常用的数据结构,如栈、队列等。Java集合还可以用于板寸具
- 应用特性:在很多复杂而小功能需要调用需求时,而且这些调用往往还有一定相关性,即一调用就是一系列的。结构特性:把原本复杂而繁多的调用,规划统一
- 在消息通知的时候,我们经常用到两个控件Notification和Toast。特
- 前几篇主要集中在注册中心eureka的使用上,接下来可以创建服务提供者provider来注册到eureka。demo源码见: https:/