.NET8.0多线程编码结合异步编码示例

news/2025/1/20 20:28:58/

1、创建一个.NET8.0控制台项目来演示多线程的应用

2、快速创建一个线程

3、多次运行程序,可以得到输出结果

这就是多线程的特点 - 当多个线程并行执行时,它们的具体执行顺序是不确定的,除非我们使用同步机制(如 lock、信号量等)来控制执行顺序。

4、新建一个类TestThread,以及一个静态的测试方法,用来做测试使用

5、在Program中,把输出改成调用TestThread类中的测试方法再次执行测试一下

6、执行以后的输出结果,如下图所示

7、Thread.Sleep(毫秒):线程的等待(睡眠)

执行结果:

8、Thread.Join() 代表线程执行完毕以后,才可以继续执行后续的代码

如下图所示,在thread线程内部执行完成以后,很快就接着执行最后的打印输出方法了

9、Thread.Join(毫秒) 代表等待当前线程执行多长时间,如果超出设定的毫秒数,就会直接执行后续的代码

运行程序,查看执行结果


1、新增Test2方法,用来测试线程池ThreadPool使用

2、WaitCallback也是一个委托,传入需要在线程池内执行的方法名称。以下代码内,“线程池”字符串为要执行方法对应的参数

ThreadPool:
这是.NET中的线程池类
它维护着一组可重用的线程
比直接创建新线程更有效率QueueUserWorkItem:
这个方法用于将工作项添加到线程池队列中
线程池会自动分配空闲线程来执行这些工作项WaitCallback:
这是一个委托类型
定义了线程池中的线程要执行的方法
可以接收一个 object 类型的参数TestThread.Test2:
这是你定义的要在线程池中执行的方法
它有这样的签名:public static void Test2(object state)"线程池":
这是传递给 Test2 方法的参数

3、除了直接传入回调方法,也可以直接在线程池开启的方法内,直接写代码块来当做多线程执行的部分

4、线程池内,可以通过设置Manual信号量,来识别线程池内的线程什么时候执行完成。


**1、创建一个TestAsyncAction类,添加一个模拟的异步方法TestAction

2、使用Task快读创建一个线程。最简单的方法:Task.Run(()=>{ 代码块 })

3、两个线程并行执行,查询执行结果

4、如果想等待新开线程执行完再继续执行后续的代码,可以使用如下方式:使用 await 等待整个操作完成

await Task.Run(async () =>
{await TestAsyncAction.TestAction();
});代码会等待异步操作完成才继续执行

执行结果:

5、也可以使用Task.Factory创建一个任务工厂来实现

6、查看执行结果


1、【异步结合多线程】如果有多个任务在执行期间,在任意一个线程执行完毕以后进行执行某种操作,可以使用 ContinueWhenAny来进行

// See https://aka.ms/new-console-template for more information
using MultiThreading;Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}>>>>Hello, World!");var tasks = new Task[3];TaskFactory factory = new();/** .Unwrap() 主要是用来处理嵌套任务问题。* 使用 StartNew 执行 async lambda 时,会得到一个 Task<Task> (双层嵌套的Task)*          // 不使用 Unwrapvar task1 = factory.StartNew(async () => {await Task.Delay(1000);return "Hello";});// task1 的类型是 Task<Task<string>>// 需要两次 awaitstring result1 = await (await task1);---------------------------------------------------// 使用 Unwrapvar task2 = factory.StartNew(async () => {await Task.Delay(1000);return "Hello";}).Unwrap();// task2 的类型是 Task<string>// 只需要一次 awaitstring result2 = await task2;*/
tasks[0] = factory.StartNew(async () =>
{await TestAsyncAction.AsyncAction1();
}).Unwrap();tasks[1] = factory.StartNew(async () =>
{await TestAsyncAction.AsyncAction2();
}).Unwrap();tasks[2] = factory.StartNew(async () =>
{await TestAsyncAction.AsyncAction3();
}).Unwrap();_ = factory.ContinueWhenAny(tasks, x =>
{Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}>>>>正常代码");
});Console.ReadLine();//阻止程序退出PS:如果后续代码依赖于续联任务的完成,使用 await如果不关心续联任务何时完成,使用 _=

查看执行结果:

2、【异步结合多线程】如果要等任务全部执行完毕以后才执行某个代码块,可以使用ContinueWhenAll

查看执行结果:

PS:
// 可以使用 Task.WhenAny 替代 ContinueWhenAny
_ = Task.WhenAny(tasks).ContinueWith(t => {Console.WriteLine(">>>>正常代码");
});

3、异步方法中 使用 WhenAll 和 WhenAny(这个仅模拟纯IO操作,不涉及多线程)

  当遇到 await 时,当前方法会返回到调用者主线程可以继续处理其他工作(比如UI响应、处理其他事件等)这些任务会被放到线程池中执行当前方法内 await 后面的代码会被打包成续接(continuation)这个续接会等待所有任务完成后才执行但这个等待是异步的,不会占用主线程资源

  • .WhenAll()

查看执行结果:

  • .WhenAny()

查看执行结果:

文章转载自:sq1201

原文链接:.NET8.0多线程编码结合异步编码示例 - sq1201 - 博客园

体验地址:引迈 - JNPF快速开发平台_低代码开发平台_零代码开发平台_流程设计器_表单引擎_工作流引擎_软件架构


http://www.ppmy.cn/news/1564745.html

相关文章

CTTSHOW-WEB入门-信息搜集11-20

web11 1. 题目&#xff1a; 2. 解题步骤及思路&#xff1a;本题的flag已经给出&#xff0c;主要考点是考察域名的查询&#xff0c;通过查询有时候也可以得到一些有用的信息。 3. 相关知识点&#xff1a;查询域名可以使用nslookup命令使用方法如下&#xff1a;&#xff08;windo…

Type-C充电与智能家居的结合

在科技日新月异的今天&#xff0c;家具已不仅仅是满足基本生活需求的物品&#xff0c;它们正逐渐融入智能化元素&#xff0c;成为提升生活品质的重要一环。其中&#xff0c;家具与USB充电技术的结合&#xff0c;正是这一趋势的生动体现。通过将USB充电端口巧妙地融入家具设计中…

WPS计算机二级•常用图表制作

听说这里是目录哦 绘制饼图&#x1f697;制作动态图表&#x1f68c;制作动态对比图表&#x1f3cd;️目标与实际对比图&#x1f3ce;️基本图表介绍&#x1f69b;线柱图&#x1f69a;能量站&#x1f61a; 绘制饼图&#x1f697; 选中表格数据单元格➡️点击上方菜单栏插入-全部…

数据仓库经典面试题

一、数据仓库基础概念 1. 什么是数据仓库&#xff1f; 答案&#xff1a;数据仓库是一个面向主题的、集成的、非易失的且随时间变化的数据集合&#xff0c;用于支持管理决策过程。解释&#xff1a;面向主题&#xff1a;围绕特定主题组织数据&#xff0c;如销售主题、客户主题&…

【零基础入门unity游戏开发——unity通用篇36】向量(Vector3)的基本操作和运算(基于unity6开发介绍)

考虑到每个人基础可能不一样,且并不是所有人都有同时做2D、3D开发的需求,所以我把 【零基础入门unity游戏开发】 分为成了C#篇、unity通用篇、unity3D篇、unity2D篇。 【C#篇】:主要讲解C#的基础语法,包括变量、数据类型、运算符、流程控制、面向对象等,适合没有编程基础的…

linux Debian包管理器apt安装软件包由于依赖关系安装失败解决方法

apt安装软件包报错提示如下&#xff0c;可参照本文尝试解决&#xff1a; 下列软件包有未满足的依赖关系&#xff1a;xxx : 依赖: libpulse-dev 但是它将不会被安装 E: 无法修正错误&#xff0c;因为您要求某些软件包保持现状&#xff0c;就是它们破坏了软件包间的依赖关系。可…

论文阅读:CosAE Learnable Fourier Series for Image Restoration

这是 2024 NeurIPS 上发表的一篇文章&#xff0c;介绍了一种新型的基于傅里叶级数的通用编码器。 Abstract 本文介绍了余弦自动编码器&#xff08;Cosine Autoencoder, CosAE&#xff09;&#xff0c;这是一种新颖的通用自动编码器&#xff0c;它将经典傅里叶级数与前馈神经网…

第1章:Python TDD基础与乘法功能测试

写在前面 这本书是我们老板推荐过的&#xff0c;我在《价值心法》的推荐书单里也看到了它。用了一段时间 Cursor 软件后&#xff0c;我突然思考&#xff0c;对于测试开发工程师来说&#xff0c;什么才更有价值呢&#xff1f;如何让 AI 工具更好地辅助自己写代码&#xff0c;或许…