C#多线程的相关操作讲解
作者：.NET开发菜鸟 发布时间：2022-01-13 18:32:12
一、线程异常
我们在单线程中，捕获异常可以使用try-catch，代码如下所示：
using System;
namespace MultithreadingOption
{
class Program
{
static void Main(string[] args)
{
#region 单线程中捕获异常
try
{
int[] array = { 1, 23, 61, 678, 23, 45 };
Console.WriteLine(array[6]);
}
catch (Exception ex)
{
Console.WriteLine($"message:{ex.Message}");
}
#endregion
Console.ReadKey();
}
}
}
程序运行结果：
那么在多线程中如何捕获异常呢？是不是也可以使用try-catch进行捕获？我们先看下面的代码：
using System;
using System.Threading.Tasks;
namespace MultithreadingOption
{
class Program
{
static void Main(string[] args)
{
#region 单线程中捕获异常
//try
//{
// int[] array = { 1, 23, 61, 678, 23, 45 };
// Console.WriteLine(array[6]);
//}
//catch (Exception ex)
//{
// Console.WriteLine($"message:{ex.Message}");
//}
#endregion
#region 多线程中的异常
try
{
for (int i = 0; i < 30; i++)
{
string str = $"main_{i}";
// 开启线程
Task.Run(() =>
{
Console.WriteLine($"{str} 开始了");
if(str.Equals("main_5"))
{
throw new Exception("main_5 发生了异常");
}
else if (str.Equals("main_11"))
{
throw new Exception("main_11 发生了异常");
}
else if (str.Equals("main_18"))
{
throw new Exception("main_18 发生了异常");
}
Console.WriteLine($"{str} 结束了");
});
}
}
catch (Exception ex)
{
Console.WriteLine($"message:{ex.Message}");
}
#endregion
Console.ReadKey();
}
}
}
程序运行结果：
我们看到结果中并没有输出异常信息，是不是没有抛出异常呢？我们起代码进行调试，看调试信息：
我们看到程序中确实也抛出了异常，但是程序却没有捕获到，那么异常去哪里了呢？异常被多线程给吞掉了，那么如何在多线程中捕获异常呢？如果把try-catch写在线程里面呢？每一个线程都是单线程的，把try-catch写在每一个线程里面就没有意义了。在多线程中捕获异常，需要使用到WaitAll()，看下面的代码：
try
{
// 定义一个Task类型的List集合
List<Task> taskList = new List<Task>();
for (int i = 0; i < 30; i++)
{
string str = $"main_{i}";
// 开启线程，并把线程添加到集合中
taskList.Add(Task.Run(() =>
{
Console.WriteLine($"{str} 开始了");
if (str.Equals("main_5"))
{
throw new Exception("main_5 发生了异常");
}
else if (str.Equals("main_11"))
{
throw new Exception("main_11 发生了异常");
}
else if (str.Equals("main_18"))
{
throw new Exception("main_18 发生了异常");
}
Console.WriteLine($"{str} 结束了");
}));
}
// 等待所有线程都执行完
Task.WaitAll(taskList.ToArray());
}
catch (Exception ex)
{
Console.WriteLine($"message:{ex.Message}");
}
我们用代码进行调试，调试结果：
这时就可以进入到catch里面了，我们监视ex，发现ex是AggregateException类型的异常，我们在进一步优化代码：
try
{
// 定义一个Task类型的List集合
List<Task> taskList = new List<Task>();
for (int i = 0; i < 30; i++)
{
string str = $"main_{i}";
// 开启线程，并把线程添加到集合中
taskList.Add(Task.Run(() =>
{
Console.WriteLine($"{str} 开始了");
if (str.Equals("main_5"))
{
throw new Exception("main_5 发生了异常");
}
else if (str.Equals("main_11"))
{
throw new Exception("main_11 发生了异常");
}
else if (str.Equals("main_18"))
{
throw new Exception("main_18 发生了异常");
}
Console.WriteLine($"{str} 结束了");
}));
}
// 等待所有线程都执行完
Task.WaitAll(taskList.ToArray());
}
catch(AggregateException are)
{
foreach (var exception in are.InnerExceptions)
{
Console.WriteLine(exception.Message);
}
}
catch (Exception ex)
{
Console.WriteLine($"message:{ex.Message}");
}
最后运行程序：
我们发现这时就可以捕获到具体的异常信息了。
二、线程取消
在上面的示例中，我们捕获到了多线程中发生的异常，并且也输出了异常信息，但是这样是不友好的。在实际开发中，我们使用多线程并发执行任务，假如其中某一个任务失败了或者发生了异常，我们希望可以通知其他的线程，都停止下来，那么该如何做呢？这时就需要使用到线程取消。
Task不能外部终止任务，只能自己终止自己。
.Net框架提供了CancellationTokenSource类，该类里面有一个bool类型的属性：IsCancellationRequested，默认是false，表示是否取消线程。还提供了一个Cancel()方法，该方法可以把IsCancellationRequested的属性值设置为true，并且不能在设置回去。代码如下：
// 实例化对象
CancellationTokenSource cts = new CancellationTokenSource();
for (int i = 0; i < 20; i++)
{
string str = $"main_{i}";
// 开启线程
Task.Run(() =>
{
try
{
Console.WriteLine($"{str} 开始了");
// 暂停
Thread.Sleep(new Random().Next(50, 100) * 100);
if (str.Equals("main_5"))
{
throw new Exception("main_5 发生了异常");
}
else if (str.Equals("main_11"))
{
throw new Exception("main_11 发生了异常");
}
if (cts.IsCancellationRequested == false)
{
Console.WriteLine($"{str} 结束了");
}
else
{
Console.WriteLine($"{str} 线程取消");
}
}
catch (Exception ex)
{
// 发生了异常，将IsCancellationRequested的值设置为true
cts.Cancel();
Console.WriteLine($"message:{ex.Message}");
}
});
}
程序运行结果：
可以看到，当有异常发生之后，有的线程就被取消了。这样就初步实现了线程取消。
在上面的示例中，我们是先开启了线程，如果发生了异常，则取消线程。那么会有这样一种情况：线程中发生了异常，可能这时候有的线程还没有开启，那么能不能就不让这些线程在开启呢？Task的Run方法有一个重载：
第二个参数就表示取消线程。而且CancellationTokenSource类里面正好有这个参数：
所以，我们可以利用Run方法的重载来实现不开启线程，代码如下：
try
{
// 实例化对象
CancellationTokenSource cts = new CancellationTokenSource();
// 创建Task类型的集合
List<Task> taskList = new List<Task>();
for (int i = 0; i < 20; i++)
{
string str = $"main_{i}";
// 开启线程 Task.run 以后 添加Token 就可以在某一个线程发生异常之后，让没有开启的线程不开启了
taskList.Add(Task.Run(() =>
{
try
{
Console.WriteLine($"{str} 开始了");
// 暂停
Thread.Sleep(new Random().Next(50, 100) * 10);
if (str.Equals("main_5"))
{
throw new Exception("main_5 发生了异常");
}
else if (str.Equals("main_11"))
{
throw new Exception("main_11 发生了异常");
}
if (cts.IsCancellationRequested == false)
{
Console.WriteLine($"{str} 结束了");
}
else
{
Console.WriteLine($"{str} 线程取消");
}
}
catch (Exception ex)
{
// 发生了异常，将IsCancellationRequested的值设置为true
cts.Cancel();
}
}, cts.Token));
}
// 等待所有线程执行完
Task.WaitAll(taskList.ToArray());
}
catch (AggregateException are)
{
foreach (var exception in are.InnerExceptions)
{
Console.WriteLine(exception.Message);
}
}
程序运行结果：
输出结果中有一句话：已取消一个任务，但是我们的代码里面没有打印这句话，这是从哪里来的呢？这是因为第二个参数Token的原因，加了这个参数以后，如果就线程发生了异常，就不在继续开启线程。
三、临时变量
我们先来看看下面一段代码：
for (int i = 0; i < 20; i++)
{
// 开启线程
Task.Run(() =>
{
Task.Run(() => Console.WriteLine($"this is {i} ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}"));
});
}
这段代码的输出结果是什么呢？我们运行程序查看结果：
可能有人会感到疑惑：为什么输出的都是20呢，而不是每次循环变量的值？这是什么原因呢。这是因为我们申请线程的时候不会发生阻塞，而且还是延迟执行的。我们知道，代码的执行速度是非常快的，循环20次几乎一瞬间就完成了，这是i就变成了20，但是线程是延迟执行的，当线程真正去执行的时候，对应的是同一个i，这时i是20，所以输出的都是20。那么该如何输出每次循环的值呢？看下面的代码：
for (int i = 0; i < 20; i++)
{
// 定义一个新的变量
int k = i;
// 开启线程
Task.Run(() =>
{
Task.Run(() => Console.WriteLine($"this is {i}_{k} ThreadId: {Thread.CurrentThread.ManagedThreadId.ToString("00")}"));
});
}
程序运行结果：
这样每次循环的时候，都重新定义变量k，保证每次都是全新的，所以k的值就是每次循环的值。
四、线程安全
什么是线程安全呢？线程安全：如果你的代码在进程中有多个线程同时运行这一段，如果每次运行的结果都跟单线程运行时的结果一致，那么就是线程安全的。
在什么情况下会出现线程安全的问题呢？
一般都是有全局变量/共享变量/静态变量/硬盘文件/数据库的值，只要多线程访问和修改，就会出现线程安全的问题。看下面的代码：
int syncNum = 0;
int AsyncNum = 0;
for (int i = 0; i < 10000; i++)
{
syncNum++;
}
Console.WriteLine($"syncNum={syncNum}"); //单线程10000 10000
for (int i = 0; i < 10000; i++)
{
Task.Run(() =>
{
AsyncNum++;
});
}
Console.WriteLine($"AsyncNum ={AsyncNum}");
程序运行结果：
这就是线程安全造成的问题。那么该如何解决这个问题呢？这时可以使用lock关键字解决。lock关键字定义如下：
private static readonly object Form_Lock = new object();//锁对象的标准写法
修改代码如下：
int syncNum = 0;
int AsyncNum = 0;
for (int i = 0; i < 10000; i++)
{
syncNum++;
}
Console.WriteLine($"syncNum={syncNum}");
for (int i = 0; i < 10000; i++)
{
Task.Run(() =>
{
lock (Form_Lock)
{
AsyncNum++;
}
});
}
// 休眠5秒，等待所有线程都执行完毕
Thread.Sleep(5000);
Console.WriteLine($"AsyncNum ={AsyncNum}");
程序运行结果：
除了使用lock，我们还可以使用数据分拆，避免多线程操作同一个数据，这样又安全又高效。
来源：https://www.cnblogs.com/dotnet261010/p/12300417.html
0
投稿猜你喜欢
- java 在Jetty9中使用HttpSessionListener和FilterHttpSessionListener当Session创建
前言任何一个服务如果没有监控，那就是两眼一抹黑，无法知道当前服务的运行情况，也就无法对可能出现的异常状况进行很好的处理，所以对任意一个服务来- 将来自客户端的请求传入一个对象，从而使你可用不同的请求对客户进行参数化。用于“行为请求者”与“行为实现者”解耦，可实现二者之间的松耦合，以便
- 前言 短时间提升自己最快的手段就是背面试题，最近总结了Java常用的面试题，分享给大家，希望大家都能圆梦大厂，加油，我命由我不由天
- 1. 前言Spring的核心技术IOC(Intorol of Converse控制反转)的实现途径是DI(dependency Insert
- 前面聊了布隆过滤器，回归认识一下位图BitMap，阅读前文的同学应该发现了布隆过滤器本身就是基于位图，是位图的一种改进。位图先看一个问题，
- 要获得打印机的状态,应该定义一个联合.enum PrinterStatus { 其他状态= 1, 未知, 空闲
- 本文所述为C#实现根据指定容器和控件名字获得控件的方法，在进行C#应用程序设计时有一定的借鉴价值。分享给大家供大家参考借鉴。具体实现方法如下
- 内部类1. 内部类简介(1) 内部类提供了更好的封装，可以把内部类隐藏在外部类之内，不允许同一个包中的其他类访问该类。(2) 内部类成员可以
- 为什么使用logback记得前几年工作的时候，公司使用的日志框架还是log4j，大约从16年中到现在，不管是我参与的别人已经搭建好的项目还是
- 开始我用List<泛型>接受json串，如下，结果list内并非泛型对象，而是JSONObject对象。这样在遍历的时候就报了转
- 避免"索引越界"错误的规则如下（针对C++）：不要使用静态或动态分配的数组，改用array或vector模板不要使用带方
- 1.Java内存模型JAVA定义了一套在多线程读写共享数据时时，对数据的可见性、有序性和原子性的规则和保障。屏蔽掉不同操作系统间的微小差异。
- 定义：将一个复杂对象的构建与它的表示分离，使得同样的构建过程可以创建不同的表示。类型：创建类模式类图：四个要素产品类：一般是一个较为复杂的对
- 前言经常使用Swagger的小伙伴应该有所体会，Swagger对于JSON的支持真的很不友好！最近发现了两款颜值很不错的JSON可视化工具，
- JDK * ,代理接口没有实现类,实现 * JDK代理，代理的是接口，那么笔者想一想，既然代理的是接口，那如果没有实现类怎么办，能不能代
- 由于要在Web项目中采用RFID读取功能，所以有必要开发Activex，一般情况下开发Activex都采用VC，VB等，但对这两块不是很熟悉
- controller传boolean形式值@GetMapping("/check-cart")public List&l
- 如何将jar包打包到指定目录今天分享一下springboot将jar包打包到指定目录下。由于之前上线都是一个打包到一个jar，由于服务多了，
- 本文主要学习Java构造器与传值，供大家参考，具体内容如下构造器构造器介绍构造器是Java学习中一个很重要的概念，每个类的对象在使用关键字n
