首页 程序笔记 .Net各版本多线程使用原理和实践

.Net各版本多线程使用原理和实践

多线程基本概念

进程:程序在服务器上运行时,占据的计算资源合集,称之为进程。

进程之间不会互相干扰,进程间的通信比较困难(分布式)。

线程:程序执行的最小单位。

线程也包含自己的计算资源,线程是属于进程的,一个进程可以又多个线程。

多线程:一个进程里面,又多个线程并发执行。

多线程Thread:类,就是一个封装,是.netFramework对线程对象的抽象封装

通过Thread去完成的操作,最终是通过向操作系统请求得到的执行流

CurrentThread:当前线程,任何操作执行都是线程完成的,运行当前这句话的线程

ManagedThreadId:是.Net平台给Thread起的名字,就是个int值,尽量不重复。

任何的异步多线程都离不开委托delegate,多线程写法不难,但是用好很难,多年老司机也经常掉坑里。以Winform开发来讲,同步单线程方法主UI线程忙于计算不能响应就会卡界面,异步多线程方法不卡界面,计算任务交给了子线程,主UI线程已经闲置,可以响应别的操作。

多线程是用资源换性能,但并不是线性增长。因为多线程有协调管理成本,资源也有上限(例如把线程比作车,虽然有50辆车,但是只有3根道,那想快也快不起来)。

多线程的特点:多线程无序性不可预测性(启动无序,结束无序)

原因:因为线程是操作系统资源,CLR只能去申请,具体是什么顺序无法控制。执行事件不确定,同一个线程同一个任务耗时可能也不同

跟操作系统的调度策略有关,CPU分片(计算能力太强,1s拆分1000份,宏观上就变成并发的)。线程的优先级可以影响操作系统的调度。

解决多线程不可预测性的方法?控制顺序

AsyncCallback 异步回调

AsyncCallback asyncCallback = (ar) => { 
    //do something
};
Action action = () => { };
action.BeginInvoke(asyncCallback, null);

IsCompleted等待

IsCompleted是一个属性,用来描述异步动作是否完成,其实一开始就是个false,异步动作完成后回去修改这个属性为true

信号量

AsyncResult.AsyncWaitHandle.WaitOne();//阻塞当前线程,直到收到信号量,无延迟
AsyncResult.AsyncWaitHandle.WaitOne(-1)一直等待直到成功
AsyncResult.AsyncWaitHandle.WaitOne(1000)等待且最多只等待1000ms超过就继续执行,用来做超时控制。

IAsyncResult异步调用结果,描述异步操作的。

func.EndInvoke(asyncResult)可以获取异步调用的真是返回值。每个异步操作,只能调用一次EndInvoke,多个会异常。

.Net多线程代码如何编写?

.NETFramework有N多个版本,就有N多个多线程的使用方式。

.NetFramework1.0 1.1 Thread

Thread的api特别丰富,但是其实都用不好,因为线程资源是操作系统管理的,相应并不灵敏,没那么好控制。Thread启动线程是没有控制的,可能导致死机。(循环创建无上限控制)

ThreadStart ts = () => {
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "ThreadStart开始运行了");
    Thread.Sleep(3000);
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "ThreadStart结束运行了");
};
Thread thread = new Thread(ts);
thread.Start();

.NetFramework2.0 ThreadPool(新的CLR)非常大的版本变化

ThreadPool线程池,池化资源管理设计思想。线程是一种资源,之前每次要用就去申请一个线程,使用完之后释放掉。池化就是做一个容器,提前申请N个线程,程序需要使用线程直接找容器获取,用完后再放回容器(控制状态标记线程是否再使用),避免频繁申请和销毁。容器自己会根据闲置的数量去申请和释放。后面的写法都是从线程池拿的。

优点:1线程服用2限制最大线程数量

缺点:Api太少了,线程等待顺序控制特别弱,影响了实战。

WaitCallback callback = o => {
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "ThreadPoolStart开始运行了");
    Thread.Sleep(3000);
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "ThreadPoolStart结束运行了");
};
ThreadPool.QueueUserWorkItem(callback);

.NETFramework3.0 Task

Task被称为多线程的最佳实践。优点:1全部是线程池线程。2提供了丰富的Api,非常适合开发实践。

下面代码列举了几个常用的API基本可以满足日常业务对执行顺序的控制。

List<Task> tasks = new List<Task>();
Action action = () => {
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "Task1开始运行了");
    Thread.Sleep(3000);
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "Task1结束运行了");
};
Task task = new Task(action);
task.Start();
var task1 = Task.Run(() =>
{
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "Task2开始运行了");
    Thread.Sleep(3000);
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + "Task2结束运行了");
});
tasks.Add(task);
tasks.Add(task1);
//Task.WaitAny(tasks.ToArray());//等待任一线程结束后执行后面代码,会阻塞当前线程
//Task.WaitAll(tasks.ToArray());//等待线程全部结束后执行后面代码,会阻塞当前线程
//下面方法不会阻塞当前线程
//Continue的后续线程,可能是新线程,也可能是刚完成任务的线程,还可能是同一个线程,不可能是主线程
TaskFactory taskFactory = new TaskFactory();
taskFactory.ContinueWhenAny(tasks.ToArray(), (one) => {
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + $"任务{one.Id}第一个完成了");
});
taskFactory.ContinueWhenAll(tasks.ToArray(), (list) =>
{
    var ids = list.Select(x => x.Id).ToArray();
    Console.WriteLine($"ThreadId-{Thread.CurrentThread.ManagedThreadId} " + $"所有任务{string.Join(",", ids)}全部完成了");
});

await/async

成对出现语法糖,简化了多线程开发,只要将普通方法加上async就变成了可以异步的方法了。

调用异步方法时,在方法前面加上await就可以等待异步方法执行完成后再执行后面的代码。

委托BeginInvoke()

这个方法在.NetCore已经取消了。

多线程应用场景

有严格实践限制的,先后顺序的,只能单线程。

用多线程是为了提升效率,各个任务可以独立并发执行。例如一个操作要查询数据库,要调用接口,要读硬盘文件,这些操作可以多线程操作,因为任务彼此不干扰。

既需要多线程来提升性能,又需要再多线程全部完成后才能执行的操作的做法

Task.WaitAll();//等待线程全部结束后执行后面代码,会阻塞当前线程,直到全部任务结束。

Task.WaitAny()//阻塞当前线程,直到任一任务结束

不阻塞当前线程的写法

TaskFactory taskFactory = new TaskFactory();

taskFactory.ContinueWhenAll()//创建一个延续任务,该任务再一组指定的任务完成后开始

taskFactory.ContinueWhenAny()//创建一个延续任务,该任务再一组指定的任务中的任一一个完成后开始

Continue的后续线程,可能是新线程,也可能是刚完成任务的线程,还可能是同一个线程,不可能是主线程

如果同时写了Continue和Wait,任务全部完成之后,但是谁前谁后无法掌控。现有的四个方法已经能够控制90%的多线程业务场景了,需要灵活应用。

多线程准则

1尽量不要线程套线程,有更优秀的方法

2子线程是不能操作界面的

1

站心网

多线程基本概念进程:程序在服务器上运行时,占据的计算资源合集,称之为进程。进程之间不会互相干扰,进程..

为您推荐

.NET C# 过滤从富文本编辑器html里的Javascript脚本

富文本编辑器在允许用户输入丰富内容的同时,也带来了跨站脚本攻击(XSS)的风险。过滤提交的 HTML 中的 <script> 脚本是防止跨站脚本攻击(XSS)的关键步骤。在 .NET C# 服务端过滤 <script> 脚本主要有以下几种方..

ZLinq:.NET 高性能 LINQ 替代方案及其使用指南

在 .NET 开发中,LINQ(Language Integrated Query)为数据查询提供了简洁且强大的语法。然而,传统的 LINQ 在处理大量数据时可能会引发性能瓶颈,主要由于频繁的内存分配和对象创建。为解决这一问题,Cysharp 团队..

.NET使用AutoMapper简化对象映射

在.NET软件开发中,常常需要将一个对象的数据转换并映射到另一个对象上。​这种手动映射的过程既繁琐又容易出错,影响开发效率和代码可维护性。​为了解决这一问题,AutoMapper应运而生。​什么是 AutoMapper?AutoM..

.NET C# RESTful API交互Refit库使用教程

Refit 是一个 .NET C# 库,它简化了与 RESTful API 的交互。Refit 受到 Square 的 Retrofit 库的启发,它将 REST API 转换为实时接口,允许你以声明方式定义 REST API 调用。Refit 的特点1. 声明式 API 定义:Refit ..

.NET C# System.Text.Json进阶使用技巧

System.Text.Json 是 .NET 中用于处理 JSON 数据的强大库。除了基本用法外,它还提供了许多进阶技巧,可以帮助你更高效、更灵活地处理 JSON 数据。以下是一些 System.Text.Json 的进阶使用技巧:1. 自定义序列化和反..

.NET Core 使用ML.NET 机器学习分析预测股票走势

在 .NET Core 中,你可以利用 ML.NET 框架来构建机器学习模型,以预测股票价格走势。以下是一个基本的实现步骤:​1. 准备数据:​收集并整理股票的历史数据,包括日期、开盘价、最高价、最低价、收盘价和成交量等信..

.NET 日志库 Serilog 使用教程

1. Serilog 简介Serilog 是 .NET 生态中强大且灵活的日志库,支持结构化日志记录,并提供多种日志接收器(Sinks),可以将日志输出到控制台、文件、数据库等不同存储介质。Serilog 适用于控制台应用、ASP.NET Core ..

ASP.Net Core WebApi几种版本控制对比

一、版本控制的好处:(1)有助于及时推出功能, 而不会破坏现有系统。(2)它还可以帮助为选定的客户提供额外的功能。API 版本控制可以采用不同的方式进行控制,方法如下:(1)在URL 中追加版本或作为查询字符串参..

C#网络编程 多线程和高并发

在任何 TCP Server 的实现中,一定存在一个 Accept Socket Loop,用于接收 Client 端的 Connect 请求以建立 TCP Connection。在任何 TCP Server 的实现中,一定存在一个 Read Socket Loop,用于接收 Client 端 Write..

.NET C# 单元测试 mock File.Exists的返回值

在 .NET 单元测试中,使用 Moq 来模拟 File.Exists 方法的返回值,可以这样做:1. 使用 Mock<FileSystem>(推荐).NET 提供了 System.IO.Abstractions 库,你可以使用 Mock<IFileSystem> 来替代 File,这样更符合依..

.NET Core 适配 鸿蒙HarmonyOS 的最新进展

.NET Core适配鸿蒙HarmonyOS的最新进展:运行能力方面目前.Net完全具备可以在OpenHarmony系统上运行的能力。其中,NativeAOT方式是较为可行的一种,它编译出的原生so不依赖glibc,可与鸿蒙系统的libc兼容,能在鸿蒙..

VS创建.NET Core项目使用Docker方式部署到Linux服务器

在 Visual Studio(VS) 中,使用 Docker 方式部署 .NET Core 项目 到 Linux 服务器,可以简化环境管理并提高部署效率。以下是完整教程:1. 在 VS 创建 .NET Core 项目并启用 Docker新建 ASP.NET Core 项目打开 Visu..

.NET C#查询全球IP地址信息 IPTools库 使用教程

IPTools 是一个用于快速查询全球 IP 地址信息的库,支持国内和国际 IP 查询,提供详细的地理位置信息(如国家、省份、城市)以及经纬度等数据。IPTools GitHub地址:https://github.com/stulzq/IPToolsIPTools.China..

2025年.NET 10 和 C# 13 新特性示例

.NET 10预计将于2025年11月正式发布,带来一系列性能优化、开发者效率提升和跨平台能力增强。尽管官方功能集仍在开发中,早期预览版与社区讨论已揭示了多项值得期待的改进。这些增强将基于.NET 9的基础,引入新语言..

.NET Core网站减少内存占用的方法

在.NET Core网站开发中,有效管理内存占用对于保证应用程序的性能和稳定性至关重要。以下是一些减少内存占用的关键策略,它们着重于代码优化、内存管理以及相关因素的综合考虑。代码层面的优化首先,编写高效的代码..

.NET平台QR二维码生成库Net.Codecrete.QrCodeGenerator使用教程

今天给大家介绍一个免费的二维码生成库 Net.Codecrete.QrCodeGenerator ,它非常简洁、易用,且可以生成符合二维码标准的二维码图像。Net.Codecrete.QrCodeGenerator是一个开源的二维码生成库,适用于.NET平台。它基..

.NET9 SDK 新版本引入了新的解决方案文件格式.slnx

微软发布了 .NET 9 SDK 的新版本, 在这个新版本中引入了新的解决方案文件格式 slnx 的支持, 现在可以从 dotnet cli 来创建和维护 slnx 了, 并且支持了从 sln 迁移到 slnx, 目前 VisualStudio 和 Rider 都已经支持了 ..

.NET10 C#13最新语法糖用法示例

.NET 10 与 C# 13 带来了更高效的语法和更灵活的类型支持,包括 params 集合扩展、新的 \e 转义序列、方法组的自然类型推断优化,以及 ref struct 允许实现接口等特性,进一步提升了开发体验和代码可读性。C# 13 引..

.NET C# Predicate泛型委托使用方法

Predicate泛型委托:表示定义一组条件并确定指定对象是否符合这些条件的方法。此委托由 Array 和 List 类的几种方法使用,用于在集合中搜索元素。 Predicate<T> 通常用于集合的筛选或搜索操作,比如在 List<T> 的 Fi..

.NET异步编程Task.Run最佳实践

在.NET开发中,Task.Run是一个非常方便的方法,用于将工作移到线程池以异步执行。然而,虽然它看似简单易用,但滥用Task.Run可能会导致一系列性能问题,如线程池耗尽、上下文切换开销过大等。本文将深入探讨Task.Run..

发表回复

返回顶部