.NET 6 多线程的几种打开方式
yuyutoo 2025-01-14 18:41 1 浏览 0 评论
前言
多线程无处不在,平常的开发过程中,应该算是最常用的基础技术之一了。以下通过Thread、ThreadPool、再到Task、Parallel、线程锁、线程取消等方面,一步步进行演示多线程的一些基础操作。欢迎大家围观。
如果大佬们有其他关于多线程的拓展,也欢迎在评论区进行留言,大佬们的知识互助,是.NET生态发展的重要一环,欢迎大佬们进行留言,帮助更多的人。
以下博客内容使用的一些环境:
系统环境:WIN 10
.NET 环境:.NET 6
VS 环境:VS 2022
其他:没了
正文
1、先创建一个.NET 6控制台项目,用来当做该博客文章的实验使用。
2、快速创建一个线程。ParameterizedThreadStart是一个委托,传入的参数是一个object类型。
代码
ParameterizedThreadStart threadStart = new((obj) => {
Console.WriteLine(#34;当前线程 的 ID = {Thread.CurrentThread.ManagedThreadId}");
});
Thread thread = new Thread(threadStart);
thread.Start();
Console.WriteLine(#34;线程ID = {thread.ManagedThreadId}");
Console.ReadLine();
3、以上代码执行结果下图所示
4、新建一个类TestThread以及一个测试方法,用来做测试使用。
5、在program里面,把输出改成调用上面的方法再进行测试一下。
6、执行以后的输出结果,如下图所示
7、线程的等待(睡眠)。最简单的方式,是直接 Thread.Sleep(毫秒);
8、Thread的Join方法。代表线程执行完毕以后,才可以继续执行后续的代码。
如下图所示,在thread线程内部执行完成以后,很快就接着执行最后的打印输出方法了。
可以和以上的第7点进行比较输出结果。
9、Thread的Join方法,还可以传入参数,参数是毫秒值。
代表等下当前线程执行多长时间,如果超出设定的毫秒数,就不等了,直接执行后续的代码。
10、新增一个Test2方法,用来测试线程池ThreadPool使用。
11、WaitCallback也是一个委托。传入需要在线程池内执行的方法名称。
以下代码内,“线程池”字符串为执行的方法对应的参数。
代码
using MultiThread;
Console.WriteLine("Hello, World!");
ThreadPool.QueueUserWorkItem(new WaitCallback(TestThread.Test2),"线程池");
Console.ReadLine();
12、除了直接传入回调方法,也可以直接在线程池开启的方法内,直接写代码块来当做多线程执行的部分。如下图所示,睡眠1000ms以及执行的方法,在线程池内运行。
13、线程池内,可以通过设置Manual信号量,来识别线程池内的线程时候执行完成。
一般用 .Set(); 和 .WaitOne(); 结对进行,如下图代码、注释部分以及执行结果。(可以对比输出时间)
14、使用Task快读创建一个线程。
如下图所示。最简单的方法:Task.Run(()=>{ 代码块;});
15、也可以用以下方式,手动进行start启动,如图的代码所示。
16、也可以使用Task.Factory创建一个任务工厂来实现。
17、如果需要等待子线程执行完毕,才执行后续操作,可以使用Wait(); 来实现。
18、如果只想等待子线程执行指定的时间,可以通过使用 Wait(毫秒数); 来实现。
这样等待,例如500ms以后,不管子线程是不是还在浪,都不会等待,直接继续执行后续代码。
19、 如果要在等待一段时间以后执行某些当做,可以使用Task.Delay(时间毫秒数).ContinuwWith( 要执行的代码块);
如下图所示的代码、注释以及运行输出结果。
20、如果有多个任务在执行期间,在任意一个线程执行完毕以后进行执行某种操作,可以使用 ContinueWhenAny来进行。
如下图所示的代码、注释和运行结果,以及图后附有源码。
代码
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>>Hello, World!");
Task[] tasks = new Task[3];
TaskFactory factory = new();
tasks[0] = factory.StartNew(x => {
Thread.Sleep(1000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> tasks 0");
},null);
tasks[1] = factory.StartNew(x => {
Thread.Sleep(2000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> tasks 1");
}, null);
tasks[2] = factory.StartNew(x => {
Thread.Sleep(3000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> tasks 2");
}, null);
factory.ContinueWhenAny(tasks, x =>
{
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 我不晓得要打印啥子 ~ ~ ");
});
Console.ReadLine();
21、如果要等任务全部执行完毕以后才执行某个代码块,可以使用ContinueWhenAll。
22、使用TaskWaitAny() 也可以实现任意任务执行完毕以后,执行后续动作。但是会占用主线程资源。
如图所示代码,大佬们应该可以看出来为什么了。
23、同样的,Task也可以在等待全部任务执行完毕以后进行执行后续动作。如下图演示。
24、Parallel允许线程并行执行。同时最大线程执行数量,类似于ThreadPool可以设置最大并发数量类似。其他不多说,看以下的代码和演示效果。
代码
using MultiThread;
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>>Hello, World!");
ParallelOptions parallelOptions = new();
parallelOptions.MaxDegreeOfParallelism = 3;
Parallel.Invoke(parallelOptions,
() =>
{
Thread.Sleep(1000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> para1");
},
() =>
{
Thread.Sleep(2000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> para2");
},
() =>
{
Thread.Sleep(3000);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> para3");
});
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 我不晓得要打印啥子 ~ ~ ");
Console.ReadLine();
25、Parallel也可以遍历执行。
代码
using MultiThread;
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>>Hello, World!");
ParallelOptions parallelOptions = new();
parallelOptions.MaxDegreeOfParallelism = 3;
Parallel.For(0, 10,parallelOptions, s =>
{
Thread.Sleep(100);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> para{s}");
});
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 我不晓得要打印啥子 ~ ~ ");
Console.ReadLine();
26、新增一个方法,用来测试多线程锁使用。
27、在不加锁的情况下执行执行以下代码,方法体几乎同时被执行。但是实际上方法体如果只允许被同时一个线程访问的话,那么这样搞肯定是会乱子的,所以需要锁。
28、加了锁以后,查看到执行的结果,时间间隔基本上是1s左右,说明该方法体确实一次只被一个线程调用了。
29、另一种锁(原子锁),可以定义一个变量来进行原子交换。它的使用场景,一般是在轮询进行处理某些业务的时候,并且同时只允许一个线程进来,就可以使用这种锁。
和lock锁区别:lock锁是代码还没执行完,线程会一直等待,等执行完了就会继续进来。
如果线程一直被创建,lock外边会堆积越来越多的线程和资源,最严重的情况会导致系统内存不断飙升直到爆满;
原子锁的作用是,用于验证代码块是不是执行完了,还没执行完,就不鸟他了,线程也不会等待下去,而是直接跳过这部分的代码,继续执行后续的操作。如果后续没事情做了,那该干嘛干嘛了。
30、原子锁执行效果如下,一部分线程判断到代码被锁住,就跳过不管了,所以就不会有输出。
31、测试线程取消。先开启一些线程,以及有关的操作,如下图所示。
32、然后执行。结果比较尴尬,显示都是第100号线程,这是因为Task是多线程,在创建过程中,可能已经让i都执行到头了,所以再次获取到的i都是最后的值,即100.
33、在创建任务之前,引入一个中间变量,用来代替被遍历的i。然后执行结果和其他代码说明,如图所示。
34、看不到异常信息,那改成Task直接走一波,然后通过Task.WaitAll();进行捕捉异常信息。
如代码注释和演示截图所示。
代码
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>>Hello, World!");
try
{
Task[] tasks = new Task[100];
CancellationTokenSource cancellation = new CancellationTokenSource();
for (int i = 0; i < 100; i++)
{
string str = i.ToString();
tasks[i]= Task.Run(() =>
{
Thread.Sleep(100);
try
{
if (str == "10")
{
throw new Exception(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 第 -{str}- 号线程开始放弃治疗~~ 线程ID = {Thread.CurrentThread.ManagedThreadId}");
}
}
catch (Exception ex)
{
cancellation.Cancel(); // 捕获异常,线程后续所有的线程都取消操作
Console.WriteLine(ex.Message);
}
cancellation.Token.ThrowIfCancellationRequested();
if (cancellation.IsCancellationRequested == false) // 默认为false,代表正常
{
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 第 -{str}- 号线程执行正常~~ 线程ID = {Thread.CurrentThread.ManagedThreadId}");
}
else
{
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 第 -{str}- 号线程执行异常~~ 线程ID = {Thread.CurrentThread.ManagedThreadId}");
}
}, cancellation.Token);
}
Task.WaitAll(tasks);
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> 我不晓得要打印啥子 ~ ~ ");
}
catch (AggregateException ae)
{
foreach (var ex in ae.InnerExceptions)
{
Console.WriteLine(#34;{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss,fff")} >>> {ex.Message}");
}
}
Console.ReadLine();
35、以上就是这篇文章的全部内容。如果对你有帮助,欢迎点赞、转发、或留言。
- 上一篇:C# 多 线 程。
- 下一篇:如何深度理解mybatis?
相关推荐
- .NET Core 中推荐使用的10大优秀库,你用到过几个?
-
概述:Microsoft的.NETCore生态系统中的中间件已经发生了重大变化,包括无缝集成到应用程序管道中的内置和第三方组件,协调客户端和服务器之间的数据流。它通过身份验证、日志记录和路由等...
- 机器学习中英文对照表
-
10-1LossFunction0-1损失函数2Accept-RejectSamplingMethod接受-拒绝抽样法/接受-拒绝采样法3AccumulatedErrorBa...
- 反应式编程之Spring Web-Flux/Project Reactor
-
介绍反应式编程代表了我们对应用程序执行模型的看法的改变。在响应式应用程序中,执行不遵循一个请求由一个线程处理的线性模型,而是以事件驱动和非阻塞的方式处理多个请求。...
- Spider详解
-
简介Spider的功能主要使用于大型的应用系统测试,它能在很短的时间内帮助我们快速地对一个应用程序的内容、功能、系统的结构和分布情况进行了解。Control右键进行爬取数据使用spider功能。在Sp...
- WebUI 如何高效进行测试
-
1.选择合适的浏览器驱动ChromeDriver:对于大多数情况,推荐使用ChromeDriver,因为它与Chrome浏览器的兼容性好,并且性能较好。...
- 《成为Rust专家》五、单元测试 (2)
-
6.3测试框架Rust的单元测试不包括其他单元测试框架中可能找到的辅助函数、夹具、测试框架或参数化测试功能。对于这些功能,你需要自己编写代码或者尝试一些库。对于基本的参数化测试,parameteri...
- JUnit5学习之一:基本操作
-
欢迎访问我的GitHubhttps://github.com/zq2599/blog_demos内容:所有原创文章分类和汇总,及配套源码,涉及Java、Docker、Kubernetes、DevOPS...
- 511基于C# Thread类的大漠多线程模板游戏实战
-
如果你的游戏检测易语言,或者,客户反馈你的脚本被频繁报毒,加入黑名单,那么我们选择微软的C#来写一个大漠的多线程模板是最好的选择。...
- 如何深度理解mybatis?
-
深度自定义mybatis回顾mybatis的操作的核心步骤...
- .NET 6 多线程的几种打开方式
-
前言多线程无处不在,平常的开发过程中,应该算是最常用的基础技术之一了。以下通过Thread、ThreadPool、再到Task、Parallel、线程锁、线程取消等方面,一步步进行演示多线程的一些基础...
- C# 多 线 程。
-
一、基本概念1、进程...
- C#多线程
-
1.概念进程,线程,应用程序的定义网上有很多资料,但是有些抽象。通俗的来讲,进程就是一旦一个应用程序开始运行,那么这个应用程序就会存在一个属于这个应用程序的进程。线程就是进程中的基本执行单元,每个进...
- 多线程在C# (.NET) 中的应用
-
在实际项目应用中我们难免会用到多线程、多进程编程方式,C#中的多线程允许你在同一时间内执行多个线程,每个线程都可以独立地执行不同的任务或者处理不同的部分。这可以帮助提高应用程序的响应性和性能。通过这...
- 如何使?C#创建?个线程?
-
在C#中,可以通过多种方式创建和启动一个线程。以下是常用的方式及其具体实现。1.使用Thread类创建线程...
- 在C#中,如何创建并启动?个新的线程?请举例说明
-
在C#中,可以使用System.Threading.Thread类创建并启动一个新的线程。以下是创建和启动线程的方式以及示例代码:创建并启动线程的步骤...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)