C#多线程开发详解

C#多线程开发详解

  • 持续更新中。。。。。
  • 一、为什么要使用多线程开发
    • 1.提高性能
    • 2.响应性
    • 3.资源利用
    • 4.任务分解
    • 5.并行计算
    • 6.实时处理
  • 二、多线程开发缺点
    • 1.竞态条件
    • 2.死锁和饥饿
    • 3.调试复杂性
    • 4.上下文切换开销
    • 5.线程安全性
  • 三、多线程开发涉及的相关概念
    • 常用概念
      • (1)lock
      • (2)查看当前工作线程信息
      • (3)主线程、前台线程、后台线程
    • 1.Thread(线程)
      • (1)创建线程
      • (2) 线程同步
      • (3)线程异步
    • 2.ThreadPool(线程池)
    • 3.Task(任务)
      • (1)Task与Thead的关系
    • 4.Task Parallel Library (TPL)(任务并行库)
    • 5.Async/Await(异步/等待)
    • 6.Monitor(监视器)
    • 7.Semaphore(信号量)
    • 8.SemaphoreSlim
    • 9.AutoResetEvent(自动复位事件)
    • 10.ManualResetEvent(手动复位事件)
    • 11.CancellationToken(取消标记)
    • 12.volatile(易失性修饰符)
    • 13.Mutex(互斥锁)
    • 14.ReaderWriterLock(读写锁)
    • 15.ReaderWriterLockSlim(轻量级读写锁)
    • 16.SpinLock
    • 17.SpinWait
    • 18.Barrier(屏障)
  • 四、多线程的异常捕获问题

持续更新中。。。。。

一、为什么要使用多线程开发

1.提高性能

多线程允许程序同时执行多个任务,从而有效利用多核处理器,加快程序的执行速度。特别是在需要处理大量计算、I/O 操作或并行任务的应用中,多线程可以显著提高性能。

2.响应性

多线程使应用能够同时处理多个用户请求或事件,提高了应用的响应性。例如,多线程可以保持用户界面的响应,即使在执行长时间操作时也能让用户继续交互。

3.资源利用

多线程可以更有效地利用系统资源,如内存和网络连接。这对于高并发服务器、网络应用和数据处理任务特别有用。

4.任务分解

将复杂任务分解为多个小任务,每个任务在不同的线程中执行,可以简化问题并提高可维护性。

5.并行计算

多线程可以用于并行计算,例如在科学计算、数据分析和图像处理领域。这有助于加速大规模计算。

6.实时处理

在实时系统中,多线程可以保证任务在规定的时间内完成,从而满足对时间敏感性的需求。

二、多线程开发缺点

1.竞态条件

多线程可能会导致竞态条件,即多个线程竞争访问共享资源,可能导致数据不一致性和错误。

2.死锁和饥饿

不正确的线程同步可能导致死锁(多个线程无法继续执行)或饥饿(某些线程无法获取所需资源)问题。

3.调试复杂性

多线程程序的调试和错误跟踪可能会更加复杂,因为线程间的交互和排错可能变得更难。

4.上下文切换开销

上下文切换(Context Switching)是多线程环境中的一种操作,指的是在一个 CPU 核心上切换正在执行的线程,从当前线程的执行上下文(包括寄存器状态、程序计数器等)切换到另一个线程的执行上下文, 线程的切换需要额外的开销,因此在某些情况下,过多的线程可能会导致性能下降。

  1. 当一个线程的时间片(时间片轮转调度算法)用完,操作系统需要挂起该线程并切换到另一个线程。
  2. 当一个线程主动放弃 CPU,例如通过调用 Thread.Sleep()、Thread.Yield() 或等待某个事件时
    3.当一个线程被高优先级的线程抢占

上下文切换的过程涉及以下步骤:

  1. 保存当前线程的上下文: 操作系统将当前线程的寄存器状态、程序计数器等信息保存到该线程的内存空间中,以便稍后能够恢复该线程的执行
    2.恢复目标线程的上下文: 操作系统从目标线程的内存空间中恢复寄存器状态、程序计数器等信息,准备让目标线程继续执行。
  2. 切换内核堆栈: 每个线程都有自己的内核堆栈,上下文切换时,操作系统会切换内核堆栈,以确保线程的隔离性。

上下文切换开销指的是从一个线程切换到另一个线程的过程中所涉及的时间和资源开销。这些开销主要包括以下几个方面:

  1. 寄存器保存和恢复: 当线程切换时,操作系统需要保存当前线程的寄存器状态,然后恢复目标线程的寄存器状态。这涉及到大量的数据拷贝和计算。
    2.内存访问: 上下文切换过程中需要频繁访问内存,包括将寄存器状态和其他上下文信息写入内存,以及从内存中读取目标线程的上下文信息。
    3.调度开销: 操作系统需要决定要切换到哪个线程,这涉及到调度算法的开销,包括选择合适的线程并进行必要的线程队列操作。
    4.TLB(Translation Lookaside Buffer)失效: 当线程切换时,虚拟内存的映射可能会发生变化,导致 TLB 缓存失效,从而增加了内存访问的开销。

上下文切换开销会影响系统的整体性能,特别是在高并发、频繁切换的情况下。因此,在设计多线程应用程序时,需要考虑如何减少上下文切换的发生,以提高程序的执行效率。一些方法包括:

  1. 使用线程池:线程池可以减少线程的创建和销毁,从而减少上下文切换的频率。
  2. 合理设置线程数量:避免创建过多线程,以减少不必要的上下文切换。
    3.使用异步编程模型:使用异步操作和任务可以减少线程的使用,从而减少上下文切换。

5.线程安全性

多线程编程需要谨慎处理线程安全性,以避免数据竞争和共享资源的冲突。

三、多线程开发涉及的相关概念

常用概念

(1)lock

在 C# 中,lock 关键字用于实现线程同步,以确保在多线程环境中对共享资源的访问是安全的。lock 关键字会创建一个互斥锁(也称为监视器锁),只有一个线程可以获得该锁,从而确保在同一时间只有一个线程能够执行被 lock 包围的代码块。

lock (lockObject)
{// 在这里执行需要同步的代码
}

其中,lockObject 是一个用于同步的对象。它可以是任何引用类型的对象,但通常是一个专门用于同步的对象。多个线程可以共享同一个 lockObject,并且只有一个线程能够获得锁并执行被 lock 包围的代码块。

class Program
{static readonly object lockObject = new object(); // 同步对象static void Main(string[] args){for (int i = 0; i < 5; i++){ThreadStart start = () =>{lock (lockObject){Console.WriteLine($"Thread {Thread.CurrentThread.ManagedThreadId} is in the critical section.");Thread.Sleep(1000);Console.WriteLine($"Thread {Thread.CurrentThread.ManagedThreadId} has exited the critical section.");}};Thread thread = new Thread(start);thread.Start();}Console.ReadKey();}
}

在这里插入图片描述

(2)查看当前工作线程信息

可以使用 Thread.CurrentThread 属性来获取当前正在执行的线程的信息。这个属性返回一个表示当前线程的 Thread 对象,你可以使用它来查询线程的各种属性和状态。

Thread 类还提供了 Priority 属性,允许你设置线程的优先级。然而,操作系统不一定会完全遵循线程的优先级,这取决于操作系统的调度机制。

线程可以分为前台线程和后台线程。前台线程是主线程的一部分,如果所有前台线程都完成,程序将终止。后台线程是在后台运行的线程,如果所有前台线程都完成,程序会立即终止,不会等待后台线程完成。

using System;
using System.Threading;class Program
{static void Main(){Thread currentThread = Thread.CurrentThread;Console.WriteLine($"Thread ID: {currentThread.ManagedThreadId}");Console.WriteLine($"Thread Name: {currentThread.Name}");Console.WriteLine($"Is Thread Background: {currentThread.IsBackground}");Console.WriteLine($"Thread Priority: {currentThread.Priority}");Console.WriteLine($"Thread State: {currentThread.ThreadState}");}
}

在这里插入图片描述

(3)主线程、前台线程、后台线程

主线程(Main Thread),它是程序的入口点,并且在程序启动时自动创建。主线程负责启动其他线程,并且通常是其他线程的父线程,但并不是所有线程都是主线程的子线程。

线程之间没有严格的父子关系。主线程和其他线程之间通常是平等的,没有直接的父子关系。但是,你可以通过编程来模拟一种线程间的层次关系,使得某些线程在逻辑上看起来是其他线程的子线程。这通常涉及线程的创建、协调和通信

以下是一个示例,演示了如何通过逻辑上的组织来模拟一种主线程和子线程的关系:

using System;
using System.Threading;class Program
{static void Main(){Console.WriteLine("Main thread starts.");Thread parentThread = new Thread(ParentThreadMethod);parentThread.Start();parentThread.Join();Console.WriteLine("Main thread ends.");}static void ParentThreadMethod(){Console.WriteLine("Parent thread starts.");Thread childThread = new Thread(ChildThreadMethod);childThread.Start();childThread.Join();Console.WriteLine("Parent thread ends.");}static void ChildThreadMethod(){Console.WriteLine("Child thread starts.");Thread.Sleep(2000);Console.WriteLine("Child thread ends.");}
}

前台线程(Foreground Threads):
这些线程是由主线程或其他前台线程创建的,它们的生命周期独立于主线程,但它们不是主线程的子线程。前台线程与主线程之间的关系是平级的。当所有前台线程都执行完毕时,程序才会退出,无论主线程是否结束。

  1. 生命周期:
    前台线程的生命周期不受其他线程的影响。即使主线程退出,前台线程仍然可以继续执行,直到完成。
  2. 程序退出:
    如果程序中还有前台线程在运行,主程序将等待所有前台线程完成后才会退出。主线程也是前台线程,如果主线程退出,会等待其他前台线程完成后再退出。
  3. 影响程序:
    前台线程会阻塞程序的退出,直到所有前台线程完成。这可能会影响程序的退出速度。
  4. 默认类型:
    == 通过 new Thread(…) 创建的线程默认是前台线程。==

在这里插入图片描述

后台线程(Background Threads):
这些线程也是由主线程或其他前台线程创建的,它们同样是平级的,不是主线程的子线程。后台线程与主线程之间的关系也是平级的。当所有前台线程结束,程序会退出,同时会终止所有后台线程,不管后台线程是否执行完毕。

  1. 生命周期:
    后台线程的生命周期受到主线程的影响。如果所有前台线程(包括主线程)都已经完成,程序会立即退出,同时终止后台线程,不管后台线程是否执行完毕。
  2. 程序退出:
    如果程序中只剩下后台线程在运行,即使主线程结束,程序也会立即退出,不会等待后台线程完成。
  3. 影响程序:
    后台线程不会阻塞程序的退出,它们对程序的退出速度没有影响。
  4. 设置后台线程:
    可以通过设置线程的 IsBackground 属性为 true 将线程设置为后台线程。通过 Thread 类创建的线程可以使用这个属性进行设置。

在这里插入图片描述

使用场景:

  1. 前台线程通常用于执行一些关键任务,确保这些任务的完成。例如,在主线程需要等待其他线程的结果时,可以使用前台线程。
  2. 后台线程通常用于执行一些非关键性的任务,如日志记录、监控等。它们不会阻止程序的退出,适用于在程序退出时不需要保证任务完全执行的情况。

错误使用后台线程,可能引起资源泄露或意外行为

  1. 资源泄露:
    如果后台线程在程序退出时还在执行,可能会导致资源无法正确释放。例如,如果后台线程打开了文件、网络连接或其他资源,但程序退出时这些资源没有被正确关闭,就会发生资源泄露。
  2. 不完整的操作:
    如果后台线程执行一些需要完整执行的操作,例如数据的写入、状态的更新等,但程序退出时这些操作未完成,可能会导致数据不一致或损坏。
  3. 异常处理:
    后台线程的异常不会被捕获并传播到主线程,可能会导致未处理的异常,影响程序的稳定性。
    4.线程同步:
    在程序退出时,后台线程可能还在等待某些同步操作完成,但这些操作可能无法在后台线程终止之前完成,可能会导致死锁或其他线程同步问题。

1.Thread(线程)

表示一个执行线程,用于并行执行代码。可以使用 Thread 类来创建和管理线程。线程是执行程序的最小单位,多线程编程允许程序同时执行多个任务,从而提高性能和响应性。

Thread 类是 C# 中用于线程操作的基础类之一。然而,对于更高级的线程编程需求,你可能会使用 Task、ThreadPool、异步编程模型等更高级的机制,以便更好地管理和协调多线程操作。

Thead常用方法

  1. Start(): 启动线程,使其开始执行指定的方法。
  2. Join(): 阻塞当前线程,直到目标线程完成。
  3. Abort(): 强制终止线程的执行。不建议使用,因为可能导致资源泄漏或不稳定的状态。
  4. Sleep(int millisecondsTimeout): 使当前线程休眠指定的毫秒数。
  5. IsAlive(): 返回一个布尔值,指示线程是否处于活动状态。
  6. Interrupt(): 中断线程,引发一个 ThreadInterruptedException 异常。
  7. Suspend() 和 Resume(): 已过时,不推荐使用。用于暂停和恢复线程的执行。
  8. GetDomain() 和 GetDomainID(): 获取线程所属的应用程序域和域标识符。
  9. SetApartmentState(ApartmentState state): 设置线程的单元状态,用于控制线程的COM互操作行为。
  10. GetCurrentThreadId() 和 GetDomainID(): 获取当前线程的唯一标识符。
  11. Interrupt(): 中断线程的等待状态,引发 ThreadInterruptedException 异常。
  12. Yield(): 提示系统允许其他等待线程运行。
  13. Name 和 CurrentThread.Name: 获取或设置线程的名称。
  14. SetData 和 GetData: 在线程范围内设置和获取线程本地存储数据。
  15. Start(ParameterizedThreadStart) 和 Start(ParameterizedThreadStart, Object): 启动线程并传递参数给线程方法。
  16. TrySetApartmentState(ApartmentState): 尝试设置线程的单元状态,返回是否成功。
  17. StartNew(Action) 和 StartNew(Action, CancellationToken): 使用 Task 类来启动线程。

这些方法提供了各种线程管理和操作的能力。然而,需要注意,一些方法已经过时,不推荐使用,而且一些方法可能会涉及多线程编程的复杂性,需要谨慎使用。在编写多线程应用程序时,确保仔细阅读文档并根据需求选择适当的方法。

(1)创建线程

通常,你需要传递一个方法作为线程的入口点,然后调用 Start 方法来启动线程。

using System;
using System.Threading;class Program
{static void Main(){Thread thread = new Thread(WorkerMethod);thread.Start(); // 启动线程}static void WorkerMethod(){Console.WriteLine("Thread is running.");}
}

(2) 线程同步

在多线程环境中,线程同步是一种确保多个线程协调工作的机制。Thread 类提供了 Join 方法,允许一个线程等待另一个线程完成。这在需要等待某个线程的结果时特别有用。

using System;
using System.Threading;class Program
{static void Main(){Thread currentThread = Thread.CurrentThread;Console.WriteLine($"Thread ID: {currentThread.ManagedThreadId}");Thread thread = new Thread(WorkerMethod);thread.Start();// 主线程等待子线程完成thread.Join();Console.WriteLine("Thread has finished.");}static void WorkerMethod(){Thread currentThread = Thread.CurrentThread;Console.WriteLine($"Thread ID: {currentThread.ManagedThreadId}");Console.WriteLine("Thread is running.");Thread.Sleep(2000); // 模拟耗时操作}
}

在这里插入图片描述

(3)线程异步

using System;
using System.Threading;class Program
{static void Main(){Thread currentThread = Thread.CurrentThread;Console.WriteLine($"Thread ID: {currentThread.ManagedThreadId}");Thread thread = new Thread(WorkerMethod);thread.Start();// 主线程等待子线程完成//thread.Join();Console.WriteLine("Thread has finished.");//这里子线程虽然还没有处理完,但是直接返回了,没有继续等待子线程,但是子线程还在继续处理工作,没有出现阻塞现象return "ok";}static void WorkerMethod(){Thread currentThread = Thread.CurrentThread;Console.WriteLine($"Thread ID: {currentThread.ManagedThreadId}");Console.WriteLine("Thread is running.");Thread.Sleep(10000); // 模拟耗时操作//这里在主线程结束后,继续在处理10s后打印Thread is WordEnd;Console.WriteLine("Thread is WordEnd.");}
}

可以思考下,主线程返回成功了,但是子线程执行失败了,这可怎么办?

在这里插入图片描述

2.ThreadPool(线程池)

是一个用于管理和重用线程的机制,可以使用 ThreadPool 类来执行异步任务。

3.Task(任务)

表示一个异步操作,可以使用 Task 类或 Task.Run 方法来创建和管理任务。

(1)Task与Thead的关系

4.Task Parallel Library (TPL)(任务并行库)

是 C# 中用于并行编程的高级库,用于处理异步和并行操作,包括数据并行和任务并行。

5.Async/Await(异步/等待)

是 C# 5.0 引入的异步编程模型,用于创建和管理异步方法和操作。

6.Monitor(监视器)

是用于实现线程同步的一种机制,用于保护共享资源,避免竞态条件。可以使用 Monitor 类或 lock 关键字来实现。

首先lock和Minitor有什么区别呢?
其实lock在IL代码中会被翻译成Monitor。也就是Monitor.Enter(obj)和Monitor.Exit(obj).

lock(obj)
{}//等价为:
try{    Monitor.Enter(obj)
}catch()
{}
finally
{Monitor.Exit(obj)
}

7.Semaphore(信号量)

用于控制并发访问资源的数量,可以使用 Semaphore 类来创建和管理信号量。

8.SemaphoreSlim

是 Semaphore 的改进版本,提供更好的性能和可伸缩性。

9.AutoResetEvent(自动复位事件)

用于线程同步,允许一个线程等待另一个线程发出信号。

10.ManualResetEvent(手动复位事件)

用于线程同步,允许一个线程等待多个线程发出信号。

11.CancellationToken(取消标记)

用于在异步操作中请求取消操作,可以在异步方法中传递给取消标记。

12.volatile(易失性修饰符)

用于标记字段,指示编译器不应该对标记字段进行优化,以确保多线程环境下的正确性。

13.Mutex(互斥锁)

是一种用于实现线程同步的机制,用于保护共享资源,防止多个线程同时访问。

14.ReaderWriterLock(读写锁)

允许多个线程同时读取共享资源,但只允许一个线程写入资源。适用于读操作频繁、写操作较少的场景。

15.ReaderWriterLockSlim(轻量级读写锁)

是 ReaderWriterLock 的改进版本,提供更好的性能和可伸缩性。

16.SpinLock

是一种自旋锁,用于短时间内的临界区保护。它使用忙等待来尝试获取锁,适用于临界区很小的情况。

17.SpinWait

用于在自旋等待期间执行自旋操作,可以根据不同的条件进行自旋。

18.Barrier(屏障)

允许多个线程在一个点上等待,直到所有线程都达到该点。适用于需要所有线程协调同步的场景。

四、多线程的异常捕获问题

相关文章

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/63201.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

学习Linux,要把握哪些重点?

不知道有没有想学习Linux&#xff0c;但又把握不住学习重点&#xff0c;找不到合适的学习方法的小伙伴&#xff0c;反正我刚开始学习Linux时就像无头苍蝇似的“乱撞”&#xff0c;没有把握住学习重点&#xff0c;不知道怎么去学&#xff0c;差点要放弃了&#xff0c;还好在慢慢…

《最强大模型平台上线,被很多行业“盯”上了》

千帆大模型 1、国内最多的模型2、国内最全的Prompt模板3、总结 千帆大模型平台是面向企业开发者的一站式大模型开发及服务运行平台&#xff0c;也是百度智能云推出的全球首个一站式企业级大模型平台。在提供全套文心大模型服务的基础上&#xff0c;还支持第三方开源大模型、各种…

【密码学】密码棒密码

密码棒密码 大约在公元前700年,古希腊军队使用一种叫做scytale的圆木棍来进行保密通信。其使用方法是这样的:把长带子状羊皮纸缠绕在圆木棍上,然后在上面写字;解下羊皮纸后,上面只有杂乱无章的字符,只有再次以同样的方式缠绕到同样粗细的棍子上,才能看出所写的内容。快速且不容…

【C++】开源:tinyxml2解析库配置使用

&#x1f60f;★,:.☆(&#xffe3;▽&#xffe3;)/$:.★ &#x1f60f; 这篇文章主要介绍tinyxml2解析库配置使用。 无专精则不能成&#xff0c;无涉猎则不能通。——梁启超 欢迎来到我的博客&#xff0c;一起学习&#xff0c;共同进步。 喜欢的朋友可以关注一下&#xff0c;…

winform 使用CommonOpenFileDialog选择文件夹或文件

选择文件夹 /// <summary> /// 选择文件夹 /// </summary> public void SelectFolder() {CommonOpenFileDialog dialog new CommonOpenFileDialog("请选择一个文件夹");dialog.IsFolderPicker true; //选择文件还是文件夹&#xff08;true:选择文件夹…

[PyTorch][chapter 47][LSTM -2]

目录: 双向LSTM torch.nn.embedding()实现词嵌入层 nn.LSTM nn.LSTMCell LSTM 情感分类例子 一 双向LSTM 1 原理 正向输出的结果是 反向输出的结果是 nn.LSTM模块他在最后会将正向和反向的结果进行拼接concat.得到 # -*- coding: utf-8 -*- """ Crea…

【FeatureBooster】Boosting Feature Descriptors with a Lightweight Neural Network

这篇论文介绍了一种轻量级网络&#xff0c;用于改进同一图像中关键点的特征描述符。该网络以原始描述符和关键点的几何属性作为输入&#xff0c;使用基于多层感知器&#xff08;MLP&#xff09;的自我增强阶段和基于Transformer的交叉增强阶段来增强描述符。增强后的描述符可以…

11-数据结构-栈和队列的应用(C语言)

栈和队列的应用 目录 栈和队列的应用 一、括号匹配&#xff08;栈&#xff09; 二、表达式的各种转换 (1)中缀转后缀(手工) (2)后缀转中缀表达式(手工) (3)中缀转后缀(栈) (4)中缀转后缀&#xff08;树&#xff09; (5)后缀表达式求值 (6)中缀表达式求值&#xff08;栈…

基于大模型的数据血缘异常归因分析

近日&#xff0c;以“元数据技术及应用创新”为主题&#xff0c;最新一季StartDT Hackathon&#xff08;奇点云黑客马拉松&#xff09;正式收官。 本期黑客松共吸引了近50位选手参赛&#xff0c;有的在实时数仓领域显神通&#xff0c;有的则再次请出了大模型。这些小组都有个共…

Angular安全专辑 —— CSP防止XSS攻击

什么是 CSP&#xff08;Content Security Policy&#xff09; CSP&#xff08;Content Security Policy&#xff09;是一种Web安全策略&#xff0c;用于减轻和防止跨站脚本攻击&#xff08;XSS&#xff09;等安全漏洞。它通过允许网站管理员定义哪些资源可以加载到网页中&#…

ELK 将数据流转换回常规索引

ELK 将数据流转换回常规索引 现象&#xff1a;创建索引模板是打开了数据流&#xff0c;导致不能创建常规索引&#xff0c;并且手动修改、删除索引模板失败 "reason" : "composable template [logs_template] with index patterns [new-pattern*], priority [2…

【Linux】进程信号之信号的处理

进程信号 三 一、信号的处理时机二、内核态与用户态1、内核态与用户态的转化2、重谈进程地址空间 三、信号的处理1、一般信号的处理流程2、捕捉信号的处理流程3、信号捕捉函数sigaction 一、信号的处理时机 在前面我们讲过信号产生和保存以后&#xff0c;我们知道进程对于产生…