首页 > 其他分享 >.NET Core多线程 (2) 异步 - 上

.NET Core多线程 (2) 异步 - 上

时间:2023-08-08 19:34:21浏览次数:53  
标签:Core 异步 IntPtr await IO var NET 多线程

去年换工作时系统复习了一下.NET Core多线程相关专题,学习了一线码农老哥的《.NET 5多线程编程实战》课程,我将复习的知识进行了总结形成本专题。

本篇,我们来复习一下异步的相关知识点,预计阅读时间10分钟。

理解异步的本质

(1)异步是什么?

举个例子,在高峰期去餐厅吃饭,会先排队拿个小票,然后去逛一下玩玩,等到排到时会被通知就餐,这时再回到餐厅就可以点餐了。

同步示意图:

异步示意图:

(2)同步有什么弊端

时间片切换成本高!

  • CPU密集型操作:编码解码、图形计算、正则表达式等
  • IO密集型操作:和硬件打交道,和DB打交道等
  • 线程太多的烦恼/代价:
  • 新开Thread是有开销的(时间、空间)
  • GC回收会冻结所有线程寻找引用根(gcroot)

程序有可能会卡死!

  • Thread会和网络驱动程序打交道(外网络地址)
  • ThreadPool中的WorkQueue任务(4000+)得不到处理
  • 异步:async/await

(3)C#如何使用异步?

ThreadPool线程池分类:

    • workThread:

      • 适用于CPU密集型,在WinDbg中标签为 ThreadPool Worker

    • IOThread:

      • 适用于IO密集型,在WinDbg中标签为 ThreadPool Completion Port

HttpClient案例演示:在下面的代码中GetContentLengthAsync异步方法中的线程就用的IOThread,可以通过WinDbg验证。

namespace ConsoleApp3
{
    class Program
    {
        static void Main(string[] args)
        {
            GetContentLengthAsync("http://cnblogs.com");

            Console.WriteLine($"主线程:{Environment.CurrentManagedThreadId}, 准备退出!");
            Console.ReadLine();
        }

        static async Task<int> GetContentLengthAsync(string url)
        {
            using (HttpClient client = new HttpClient())
            {
                var content = await client.GetStringAsync(url);

                Console.WriteLine($"当前线程:{Environment.CurrentManagedThreadId}, content={content.Length}");

                return content.Length;
            }
        }
    }
}

异步的底层:IO完成端口

(1)理解IO完成端口

异步的核心:callback机制

IO完成端口:这是一个Windows内核对象,我们常称之为IOCP。IOCP是一个异步I/O的Windows API,它可以高效地将I/O事件通知给应用程序,类似于Linux中的Epoll。因此,.NET Framework是基于IOCP来实现的异步,而.NET Core则增加了基于epoll来实现异步,因为它要支持跨平台而不只是Windows。SafeHandle:文件句柄、网络句柄...

核心步骤:

  • 初始化时将SafeHandle、ThreadPool与IO完成端口进行绑定(比如:FileStream在Init时)

  • (主线程)创建IO完成端口:CreateIoCompletionPort(IntPtr FileHandle, IntPtr ExistingCompletionPort, IntPtr CompletionKey, uint NumberOfConcurrentThreads)

  • (主线程)将消息塞到IO完成端口的Queue队列:PostQueuedCompletionStatus

  • (子线程)从IO完成端口的Queue队列中获取消息:GetQueuedCompletionStatu

(2)实现一个简单的IO完成端口

自定义一个IOCP类,代码如下:

public class IOCP
{
    [DllImport("kernel32.dll", CharSet = CharSet.Auto, SetLastError = true)]
    public static extern SafeFileHandle CreateIoCompletionPort(IntPtr FileHandle, IntPtr ExistingCompletionPort, IntPtr CompletionKey, uint NumberOfConcurrentThreads);

    [DllImport("kernel32.dll", CharSet = CharSet.Auto, SetLastError = true)]
    public static extern bool GetQueuedCompletionStatus(SafeFileHandle CompletionPort,
        out uint lpNumberOfBytesTransferred, out IntPtr lpCompletionKey,
        out IntPtr lpOverlapped, uint dwMilliseconds);

    [DllImport("Kernel32", CharSet = CharSet.Auto)]
    public static extern bool PostQueuedCompletionStatus(SafeFileHandle CompletionPort, uint dwNumberOfBytesTransferred, IntPtr dwCompletionKey, IntPtr lpOverlapped);
}

调用端代码如下:

// 1. 创建IO完成端口
var safehandle = IOCP.CreateIoCompletionPort(new IntPtr(-1), IntPtr.Zero, IntPtr.Zero, 1);

var thread = new Thread(() =>
{
    Console.WriteLine($"工作线程: {Environment.CurrentManagedThreadId} 开始获取数据...");
    while (true)
    {
        // 3. get数据
        IOCP.GetQueuedCompletionStatus(safehandle, out var ipn, out var ipc, out var lop, int.MaxValue);

        var receiveData = Convert.ToString(GCHandle.FromIntPtr(lop).Target);

        Console.WriteLine($"工作线程: {Environment.CurrentManagedThreadId} 获取数据成功!{receiveData}");

        Thread.Sleep(1000);
    }
});

thread.Start();

// 2. post 数据
var data = (IntPtr)GCHandle.Alloc("hello world");

IOCP.PostQueuedCompletionStatus(safehandle, 4096, IntPtr.Zero, data);

Console.WriteLine($"主线程: {Environment.CurrentManagedThreadId} 塞入数据成功!");

Console.ReadLine();

加深对异步的理解

我们都知道 ContinueWith 主要起 延续任务的作用,写起来十分繁琐!.NET 4.5推出了语法糖async/await大大简化了异步编程的工作量

下面展示使用ContinueWith 和 async/await 的两种方式的代码量:

/// <summary>
/// continutewith 的版本
/// </summary>
/// <returns></returns>
static Task<List<string>> GetContentListContinute()
{
    var list = new List<string>();

    SqlConnection connection = new SqlConnection("Server=LocalHost; Persist Security Info=False;Integrated Security=SSPI;Database= PostDB;");

    var task = connection.OpenAsync().ContinueWith(t =>
        {
            SqlCommand command = new SqlCommand("select PostContent from Post", connection);

            return command.ExecuteReaderAsync().ContinueWith(t2 =>
            {
                var reader = t2.Result;

                return GetContent(reader, list).ContinueWith(t3 =>
                {
                    return list;
                });
            }).Unwrap();

        }).Unwrap();

    return task;
}

static Task<bool> GetContent(SqlDataReader reader, List<string> list)
{
    return reader.ReadAsync().ContinueWith(t =>
    {
        var hasRow = t.Result;

        if (hasRow)
        {
            list.Add(reader.GetString(0));  //读取reader的值
            GetContent(reader, list);
        }

        return false;
    });
}

/// <summary>
/// await+async 的异步写法
/// </summary>
/// <returns></returns>
static async Task<List<string>> GetContentListAsync()
{
    List<string> list = new List<string>();

    SqlConnection connection = new SqlConnection("Server=LocalHost; Persist Security Info=False;Integrated Security=SSPI;Database= PostDB;");

    await connection.OpenAsync();

    SqlCommand command = new SqlCommand("select PostContent from Post", connection);

    var reader = command.ExecuteReader();

    while (await reader.ReadAsync())
    {
        list.Add(reader.GetString(0));
    }

    return list;
}

async/await语法糖的底层原理

从编译后的IL代码来看,async/await只是编译器提供的语法糖,它并不是一种新的异步模型,而只是一种简化异步代码编写的方式。

从反编译后的代码来看,对于async/await的方法编译器会新生成一个实现了IAsyncStateMachine接口的状态机类。

(1)IAsyncStateMachine接口定义:

public interface IAsyncStateMachine
{
    void MoveNext();
    void SetStateMachine(IAsyncStateMachine stateMachine);
}

(2)IAsyncStateMachine实现类的基本执行步骤

  • step1.初始化一个异步状态机machine

  • step2.初始化一个AsyncTaskMethodBuilder的实例,赋予machine.builder

  • step3.设置异步状态机的状态为-1,将类传入到状态机内部

  • step4.调用machine.builder的start方法

  • step5.返回machine.builder.Task

(3).NET提供异步方式的总结:

  • .NET 4.5开始提供的async/await,本质是.NET 4.0的Task + 状态机

  • .NET 4.0开始提供的Task,本质是.NET 3.5提供的Thread+ThreadPool+等待/取消等API操作

小结

本篇,我们复习了异步相关的基础知识,但由于内容太多,因此将其拆分为了两篇推文。下一篇,我们继续异步相关知识。

参考资料

一线码农,腾讯课堂《.NET 5多线程编程实战

不明作者,《Task调度与await》

 

作者:周旭龙

出处:https://edisonchou.cnblogs.com

本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接。

标签:Core,异步,IntPtr,await,IO,var,NET,多线程
From: https://www.cnblogs.com/edisonchou/p/dotnet_multithread_learning_notes_chap2.html

相关文章

  • .Net Core WebApi
    目录MiniMalAPiDemoProgram.csSwagger文档+信息Program.csAPI版本控制ApiVersion.csVersion1Controller.csProgram.cs生成注释解决跨域.Net后台请求封装返回数据压缩默认压缩Gzip压缩缓存接口缓存静态文件缓存MiniMalAPi最小的api,请求都写在Program.cs中,可以做微服务D......
  • Docker(.Net6) 环境下使用 Haukcode.WkHtmlToPdfDotNet
     背景: 项目使用的是.Net6+Docker,需要将数据生成PDF保存到第三方文件存储服务器上。引用NuGet:Haukcode.WkHtmlToPdfDotNet 这个插件还是满好用的,支持Windows、Docker.可以直接通过Url转PDF,也可以通过Html字符,生成PDF.官方地址:https://github.com/Hak......
  • 在windows上使用_netrc文件让Git记住用户名和密码(Linux文件名为.netrc)
    windowsnetrc文件是什么。根据我搜索到的结果,windowsnetrc文件是一种用于保存网络身份验证信息的文件,例如用户名和密码。它可以被一些命令行工具和应用程序使用,比如Git、curl、ftp等。windowsnetrc文件的格式如下:machine<hostname>login<username>password<password>......
  • new Thread().start(); - 多线程练习
     用Java创建一个线程是这样的:Threadthread=newThread();要启动Java线程,您将调用其start()方法,如下所示:   thread.start();此示例未指定要执行的线程的任何代码。线程启动后会立即再次停止。所以要往线程里写入代码。Threadthread=newThread(){@Override......
  • Log4netHelper, 支持自定义日志文件生成间隔
    usinglog4net;usinglog4net.Appender;usinglog4net.Config;usinglog4net.Repository;usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tasks;usingstaticlog4net.Appender.FileAppender;namespa......
  • 记一次 .NET某报关系统 非托管泄露分析
    一:背景1.讲故事前段时间有位朋友找到我,说他的程序内存会出现暴涨,让我看下是怎么事情?而且还告诉我是在Linux环境下,说实话在Linux上分析.NET程序难度会很大,难度大的原因在于Linux上的各种开源工具主要是针对C/C++,和.NET一毛钱关系都没有,说到底微软在Linux上的调试领域支......
  • 掌握.NET多线程编程技术
    当涉及到处理并发任务、提高程序性能以及充分利用多核处理器时,.NET多线程编程技术就变得至关重要。在本篇博客中,我将为您介绍一些.NET多线程编程的基本概念和技术,并附上一些示例代码来帮助您更好地理解。为什么使用多线程编程?多线程编程允许在同一进程中同时执行多个线程,从而充分利......
  • ASP.NET Core 中的显示和编辑器模板
    显示模板和编辑器模板指定了自定义类型的用户界面布局。考虑下列 Address 模型:C#复制 publicclassAddress{publicintId{get;set;}publicstringFirstName{get;set;}=null!;publicstringMiddleName{get;set;}=null!;publicst......
  • C#/.NET/.NET Core优秀项目和框架每周精选(坑已挖,欢迎大家踊跃提交PR或者Issues中留言)
    思维导航前言项目地址项目分类(善用Ctrl+F)项目列表加入DotNetGuide技术交流群前言注意:排名不分先后,都是十分优秀的开源项目和框架,每周定期更新分享(欢迎关注公众号:追逐时光者,第一时间获取每周精选分享资讯......
  • 第五节:EF Core中的三类事务(SaveChanges、DbContextTransaction、TransactionScope)
    第五节:EFCore中的三类事务(SaveChanges、DbContextTransaction、TransactionScope)原文链接:https://blog.csdn.net/weixin_30954265/article/details/101542615?spm=1001.2101.3001.6661.1&utm_medium=distribute.pc_relevant_t0.none-task-blog-2~default~CTRLIST~Rate-1-10154......