C#开发基础之I/O 异步和多线程异步：本质上的区别与使用场景

2024-08-23 22:52
文章标签 c# 基础 使用 开发 多线程 场景 区别 异步 .net netcore 本质

本文主要是介绍C#开发基础之I/O 异步和多线程异步：本质上的区别与使用场景，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在这里插入图片描述

前言

在桌面软件开发中，异步编程是一种至关重要的技巧，尤其是在需要提高应用程序响应性和并发处理能力时。常见的异步编程模式主要包括 I/O 异步和多线程异步，这两者虽然都实现了非阻塞操作，但在本质上有着显著的区别。理解它们的区别有助于开发者在不同场景下做出更为合适的设计选择。

1. I/O 异步的本质

在这里插入图片描述

I/O 异步 是指利用操作系统提供的异步 I/O 支持，来执行文件读写、网络请求等 I/O 操作，而不占用应用程序的线程资源。

  • 工作原理：当发起 I/O 操作时，操作系统会将操作委托给底层的硬件或系统服务处理，并立即返回给应用程序。应用程序通过 await 等机制等待操作完成，但期间不会阻塞线程。

  • 性能优势：由于 I/O 异步操作无需占用应用程序的线程资源，它能够更高效地处理大量并发的 I/O 请求，尤其是在需要等待外部资源（如网络、磁盘）的响应时，I/O 异步能够显著减少线程的空闲等待时间。

  • 适用场景：

    • 文件读写：如读取或写入大文件时，可以通过 FileStream.WriteAsync 或 FileStream.ReadAsync 来实现异步文件操作。
    • 网络通信：如处理 HTTP 请求或数据库查询时，利用 HttpClient.SendAsync 或 SqlCommand.ExecuteReaderAsync 可以避免网络延迟导致的线程阻塞。

代码示例：

using System;
using System.IO;
using System.Text;
using System.Threading.Tasks;class Program
{static async Task Main(string[] args){string filePath = "example.txt";byte[] data = Encoding.UTF8.GetBytes("Hello, I/O Async!");using (FileStream fs = new FileStream(filePath, FileMode.Create, FileAccess.Write, FileShare.None, bufferSize: 4096, useAsync: true)){await fs.WriteAsync(data, 0, data.Length);Console.WriteLine("Data written to file using I/O Async.");}}
}

在这个示例中，文件写入操作是异步进行的，线程不会在等待 I/O 操作完成时被阻塞。
在这里插入图片描述

2. 多线程异步的本质

在这里插入图片描述

多线程异步 是通过在多个线程中并行执行任务来实现异步操作的。这种方式通常使用 Task.Run 等方法，将任务提交给线程池运行。

  • 工作原理：当你调用 Task.Run 时，CLR 会从线程池中分配一个线程来执行传递给它的任务。任务完成后，线程将被释放或返回线程池供其他任务使用。

  • 性能特点：多线程异步适合处理需要占用大量计算资源的任务，尤其是 CPU 密集型任务。然而，由于依赖线程池的线程资源，线程的创建、调度和销毁可能带来一定的性能开销，尤其是在高并发场景中。

  • 适用场景：

    • 计算密集型任务：如复杂算法计算、图像处理、数据分析等需要大量 CPU 资源的任务。
    • 后台处理：需要在后台执行的非 I/O 操作任务，如日志记录、数据备份等。

代码示例：

多线程异步计算质数的数量，这个示例程序通过 Task.Run 将一个计算质数数量的任务放在后台线程中执行，避免阻塞主线程。

using System;
using System.Threading.Tasks;class Program
{static async Task Main(string[] args){int start = 2;int end = 1000000;Console.WriteLine("Starting prime number calculation...");// 使用 Task.Run 在后台线程中执行计算int primeCount = await Task.Run(() => CountPrimes(start, end));Console.WriteLine($"Number of prime numbers between {start} and {end}: {primeCount}");}static int CountPrimes(int start, int end){int count = 0;for (int i = start; i <= end; i++){if (IsPrime(i)){count++;}}return count;}static bool IsPrime(int number){if (number < 2) return false;for (int i = 2; i <= Math.Sqrt(number); i++){if (number % i == 0) return false;}return true;}
}

在这里插入图片描述

在这个示例中，是计算某个范围内（例如 2 到 1,000,000）质数的数量。这是一项计算密集型任务，因为它需要逐个检查每个数字是否为质数。我们使用 Task.Run 将计算质数的任务交给后台线程执行，而主线程则可以继续处理其他任务或保持响应。CountPrimes 方法会遍历指定范围内的所有数字，使用 IsPrime 方法判断每个数字是否为质数，然后统计质数的数量。通过 await Task.Run(…)，主线程等待计算完成后输出结果，但在等待期间不会阻塞其他操作。

3. I/O 异步与多线程异步的对比

  • 资源利用：

    • I/O 异步：利用操作系统的异步 I/O 支持，不占用应用程序的线程资源。
    • 多线程异步：占用线程池资源，适合 CPU 密集型任务，但可能面临线程争用和上下文切换的开销。

  • 性能与扩展性：

    • I/O 异步：更适合处理大量并发的 I/O 操作，避免线程阻塞，提高系统的并发能力。
    • 多线程异步：适合并行处理计算任务，但需要注意线程资源的开销。

  • 适用场景：

    • I/O 异步：文件读写、网络通信、数据库查询等 I/O 密集型任务。
    • 多线程异步：复杂计算、数据处理、后台处理等 CPU 密集型任务。

4. 提问：异步写入数据库适合使用哪种方案？

思考3秒钟。。。
你想到了吗？异步写入数据库通常适合使用I/O 异步方案，而不建议使用多线程异步方案。

1. I/O 异步的优势

数据库操作本质上是 I/O 密集型任务，涉及网络请求和磁盘 I/O 操作。当你执行数据库查询、插入、更新或删除操作时，应用程序需要等待数据库服务器的响应。这种等待时间可以通过 I/O 异步方式处理，使得线程不必在等待过程中被阻塞，从而更有效地利用系统资源。

2. 如何使用 I/O 异步写入数据库

在 .NET 中，常见的数据库访问库如 Entity Framework Core 和 Dapper 都提供了异步方法来执行数据库操作。这些方法通常以 Async 结尾，如 SaveChangesAsync()、ExecuteAsync()、QueryAsync() 等。

示例：使用 Entity Framework Core 的 I/O 异步写入数据库

using System;
using System.Threading.Tasks;
using Microsoft.EntityFrameworkCore;class Program
{static async Task Main(string[] args){using (var context = new MyDbContext()){var newRecord = new MyEntity { Name = "New Record", CreatedDate = DateTime.Now };context.MyEntities.Add(newRecord);// 异步保存更改到数据库await context.SaveChangesAsync();Console.WriteLine("Record added to the database asynchronously.");}}
}public class MyDbContext : DbContext
{public DbSet<MyEntity> MyEntities { get; set; }protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder){optionsBuilder.UseSqlServer("YourConnectionStringHere");}
}public class MyEntity
{public int Id { get; set; }public string Name { get; set; }public DateTime CreatedDate { get; set; }
}

3. 不建议使用多线程异步的原因

  • 高并发场景：当需要处理大量并发的数据库写入操作时，使用 I/O 异步可以避免线程阻塞，从而提升系统的并发处理能力。
  • 后台服务：在后台任务或 Web API 中，需要对数据库进行大量写操作时，I/O 异步方法能确保服务器资源得到更好的利用，避免线程长时间等待数据库响应。
  • 线程资源浪费：多线程异步通过线程池中的线程来处理任务，如果用它来执行数据库写入操作，线程在等待数据库响应时会被阻塞，导致线程资源浪费。
  • 性能问题：在高并发情况下，大量线程同时等待数据库响应可能会导致线程池耗尽，降低应用程序的性能和响应性。

5. 提问：异步处理对导入的excel数据进行逐行校验，适合使用哪种方案？

思考3秒钟。。。
你想到了吗？从 Excel 导入的数据并进行批量校验通常适合使用多线程异步方案，而不建议使用 I/O 异步方案。

1. 多线程异步的优势

多线程异步非常适合用于处理从 Excel 文件导入的数据进行批量校验的场景。通过合理利用多线程，可以显著提高数据处理速度，尤其是在面对大量数据时。确保任务合理调度与线程安全性，将使得整个数据导入与校验过程更加高效和可靠。

2. 如何使用多线程异步

假设我们需要从 Excel 文件中导入数据并逐行进行校验，这个场景可以很好地利用多线程异步来加速校验过程。

示例：多线程异步校验 Excel 数据

using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using OfficeOpenXml; // 需要安装 EPPlus NuGet 包class Program
{static async Task Main(string[] args){var data = LoadExcelData("data.xlsx");Console.WriteLine("Starting data validation...");// 使用多线程异步方式并行校验数据var validationTasks = data.Select(row => Task.Run(() => ValidateRow(row))).ToArray();// 等待所有校验任务完成var validationResults = await Task.WhenAll(validationTasks);// 处理校验结果var invalidRows = validationResults.Where(result => !result.IsValid).ToList();Console.WriteLine($"Data validation completed. Invalid rows: {invalidRows.Count}");}static List<string[]> LoadExcelData(string filePath){var rows = new List<string[]>();// 使用 EPPlus 从 Excel 文件中加载数据using (var package = new ExcelPackage(new FileInfo(filePath))){ExcelWorksheet worksheet = package.Workbook.Worksheets[0];int rowCount = worksheet.Dimension.Rows;for (int row = 2; row <= rowCount; row++) // 假设第一行为表头{var rowData = new string[worksheet.Dimension.Columns];for (int col = 1; col <= worksheet.Dimension.Columns; col++){rowData[col - 1] = worksheet.Cells[row, col].Text;}rows.Add(rowData);}}return rows;}static ValidationResult ValidateRow(string[] row){// 模拟数据校验逻辑，如检查数据格式是否正确bool isValid = row.Length > 0 && !string.IsNullOrWhiteSpace(row[0]) && row[2].Contains("@");return new ValidationResult { IsValid = isValid, RowData = row };}
}class ValidationResult
{public bool IsValid { get; set; }public string[] RowData { get; set; }
}

程序从一个 Excel 文件中导入数据，然后对每一行数据进行校验。校验逻辑可以根据具体业务需求设定，例如检查邮箱地址的格式、必填字段是否为空等。每一行的校验任务被分配到一个独立的线程中，通过 Task.Run 实现并行处理。这样可以在处理大量数据时显著提高效率。示例中使用了 EPPlus 库来读取 Excel 文件内容，这是一个非常流行且功能强大的 .NET 库，用于处理 Excel 文件。程序将所有校验失败的行记录下来，方便进一步处理或报告。

3. 建议使用场景

  • 批量数据导入与校验：如导入客户信息、订单数据、库存数据等，需要对每一行数据进行校验的场景。
  • 高并发数据处理：在处理大量 Excel 数据时，多线程可以显著提升处理速度。

5. 最佳实践

  • I/O 操作优先使用 I/O 异步：在处理文件、网络、数据库等 I/O 操作时，应优先选择使用 I/O 异步方法，如 FileStream.WriteAsync、HttpClient.SendAsync 等，避免浪费线程资源。

  • 计算密集型任务使用多线程异步：对于需要大量计算的任务，可以使用 Task.Run 将其放到后台线程执行，避免阻塞主线程，从而保持 UI 响应性或处理其他任务。

  • 避免滥用 Task.Run：虽然 Task.Run 是一种便捷的异步实现方式，但滥用可能导致线程池资源枯竭，尤其是在高并发环境下。应根据任务的性质选择最合适的异步方法。建议根据任务的复杂度和系统资源合理调度任务，避免一次性创建过多的并发任务

  • 对于简单的任务或轻量级的计算，不建议使用 Task.Run，可以直接在主线程中处理。

总结

理解 I/O 异步与多线程异步的本质区别，有助于开发者在不同场景中选择最合适的异步编程模型。I/O 异步更适合处理 I/O 密集型任务，而多线程异步则适合处理 CPU 密集型任务。合理地选择与应用这两种异步方式，可以显著提升应用程序的性能与响应性。

参考稳定

  • 异步文件 I/O
  • 对CPU密集型任务使用并行性，对I/O密集型任务使用 async/await

扫码关注微信公众，回复“dotnet” 免费获取更多pdf书籍
在这里插入图片描述

这篇关于C#开发基础之I/O 异步和多线程异步：本质上的区别与使用场景的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1100726。

相关文章

Java中String字符串使用避坑指南

Java中String字符串使用避坑指南

《Java中String字符串使用避坑指南》Java中的String字符串是我们日常编程中用得最多的类之一,看似简单的String使用,却隐藏着不少“坑”,如果不注意,可能会导致性能问题、意外的错误容... 目录8个避坑点如下：1. 字符串的不可变性：每次修改都创建新对象2. 使用 == 比较字符串，陷阱满
阅读更多...
Python使用国内镜像加速pip安装的方法讲解

Python使用国内镜像加速pip安装的方法讲解

《Python使用国内镜像加速pip安装的方法讲解》在Python开发中,pip是一个非常重要的工具,用于安装和管理Python的第三方库,然而,在国内使用pip安装依赖时,往往会因为网络问题而导致速... 目录一、pip 工具简介1. 什么是 pip？2. 什么是 -i 参数？二、国内镜像源的选择三、如何
阅读更多...
使用C++实现链表元素的反转

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定
阅读更多...
Linux使用nload监控网络流量的方法

Linux使用nload监控网络流量的方法

《Linux使用nload监控网络流量的方法》Linux中的nload命令是一个用于实时监控网络流量的工具,它提供了传入和传出流量的可视化表示,帮助用户一目了然地了解网络活动,本文给大家介绍了Linu... 目录简介安装示例用法基础用法指定网络接口限制显示特定流量类型指定刷新率设置流量速率的显示单位监控多个
阅读更多...
Java中ArrayList和LinkedList有什么区别举例详解

Java中ArrayList和LinkedList有什么区别举例详解

《Java中ArrayList和LinkedList有什么区别举例详解》：本文主要介绍Java中ArrayList和LinkedList区别的相关资料,包括数据结构特性、核心操作性能、内存与GC影... 目录一、底层数据结构二、核心操作性能对比三、内存与 GC 影响四、扩容机制五、线程安全与并发方案六、工程
阅读更多...
JavaScript中的reduce方法执行过程、使用场景及进阶用法

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》：本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程
阅读更多...
C#中读取XML文件的四种常用方法

C#中读取XML文件的四种常用方法

《C#中读取XML文件的四种常用方法》Xml是Internet环境中跨平台的,依赖于内容的技术,是当前处理结构化文档信息的有力工具,下面我们就来看看C#中读取XML文件的方法都有哪些吧... 目录XML简介格式C#读取XML文件方法使用XmlDocument使用XmlTextReader/XmlTextWr
阅读更多...
如何使用Java实现请求deepseek

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2
阅读更多...
python使用fastapi实现多语言国际化的操作指南

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本
阅读更多...
Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

《Android悬浮窗开发示例((动态权限请求|前台服务和通知|悬浮窗创建)》本文介绍了Android悬浮窗的实现效果,包括动态权限请求、前台服务和通知的使用,悬浮窗权限需要动态申请并引导... 目录一、悬浮窗 动态权限请求1、动态请求权限2、悬浮窗权限说明3、检查动态权限4、申请动态权限5、权限设置完毕后
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2