跳转至

C# 异步编程

简介

内容来源于微软MVP solenovex(杨旭)老师的视频教程《C# 异步编程》,选自书籍《C#7 核心技术指南》第14章。

原视频发布于B站,但是视频已被移除,我看的是本地缓存,目前solenovex的B站主页,已经移除了C#相关视频,专注于Math、Rust相关方向的分享。

线程

  1. 线程是一个可执行路径,它可以独立于其它线程执行
  2. 每一个线程都在操作系统的进程(Process)内支线,而操作系统进程提供了程序运行的独立环境
  3. 单线程应用,在进程的独立环境里只跑一个线程,所以该线程拥有独占权
  4. 多线程应用,单个进程中会跑多个线程,它们会共享当前的执行环境(尤其是内存) 例如,一个线程在后台读取数据,另一个线程在数据到达后进行展示 这个数据就被称作是共享的状态
  5. 例子:
  6. 在单核计算机上,操作系统必须为每个线程分配“时间片”(在Windows中通常为20毫秒)来模拟并发,从而导致重复的x和y块
  7. 在多核或多处理器计算机上,这两个线程可以真正地并行执行(可能受到计算机上其它活动进程的竞争)
  8. 在本例中,由于控制台处理并发请求的机制的微妙性,您仍然会得到重复的x和y块
public static void Main()
{
    //开辟了一个新的线程 Thread
    Thread t=new Thread(WriteY);
    t.Start();//运行WirteY
    Console.WriteLine("Thread t has ended!");

    //同时在主线程也做一些工作
    for(int i=0;i<10;i++)
    {
        Console.Write("x");
    }
}

public static void WriteY()
{
    for(int i=0;i<1000;i++)
    {
        Console.Write("y");
    }
}

image-20250414213234488

  1. 术语:线程被抢占 线程在这个时候就可以被称为抢占了:它的执行与另外一个线程上代码的执行交织的那一点。

线程的一些属性

  1. 线程一旦开始执行,IsAlive就是true,线程结束就变成false
  2. 线程结束的条件就是:线程构造函数传入的委托结束了执行
  3. 线程一旦结束,就无法再重启
  4. 每个线程都有个Name属性,通常用于调试 线程Name只能设置一次,以后更改就会抛出异常
  5. 静态的Thread.CurrentThread属性,会返回当前执行的线程
public static void Main()
{
    //开辟了一个新的线程 Thread
    Thread t=new Thread(WriteY);
    t.Name="Y Thread ...";
    t.Start();//运行WirteY

    Console.WriteLine("Thread.CurrentThread.Name");
    //同时在主线程也做一些工作
    for(int i=0;i<10;i++)
    {
        Console.Write("x");
    }
}

public static void WriteY()
{
    Console.WriteLine(Thread.CurrentThread.Name);
    for(int i=0;i<1000;i++)
    {
        Console.Write("y");
    }
}

image-20250414213836147

Join and Sleep

  1. 调用Join方法,就可以等待另一个线程结束 可以理解为“等待该线程终止”,也就是在子线程调用了Join()方法后面的代码,只有等到子线程结束了
public static void Main()
{
    Thread t=new Thread(Go);
    t.Start();
    t.Join();
    Console.WriteLine("Thread t has ended!");
}

public static void Go()
{
    for(int i=0;i<1000;i++)
    {
        Console.Write("y");
    }
}

image-20250414215315948

  1. 添加超时: 调用Join的时候,可以设置一个超时,用毫秒或者TimeSpan都可以   如果返回true,那就是线程结束了   如果超时了(在限制时间内未完成),就返回false