C# - 多线程
线程被定义为程序的执行路径。每个线程都定义一个唯一的控制流。如果您的应用程序涉及复杂且耗时的操作,那么设置不同的执行路径或线程通常会很有帮助,每个线程执行一项特定的任务。
线程是轻量级进程。使用线程的一个常见示例是现代操作系统实现并发编程。使用线程可以节省 CPU 周期的浪费并提高应用程序的效率。
到目前为止,我们编写的程序都是单个线程作为单个进程运行,该进程是应用程序的运行实例。但是,这样应用程序一次只能执行一项任务。为了使其一次执行多个任务,可以将其拆分为更小的线程。
线程生命周期
线程的生命周期从创建 System.Threading.Thread 类的对象开始,到线程终止或完成执行时结束。
以下是线程生命周期中的各种状态 -
未启动状态 - 线程实例已创建,但尚未调用 Start 方法。
就绪状态 - 线程已准备好运行并等待 CPU 周期。
不可运行状态 - 线程在以下情况下不可执行:
- 已调用 Sleep 方法
- 已调用 Wait 方法被调用
- 被 I/O 操作阻塞
死亡状态 − 线程完成执行或中止时的状态。
主线程
在 C# 中,System.Threading.Thread 类用于处理线程。它允许在多线程应用程序中创建和访问单个线程。进程中第一个执行的线程称为主线程。
当 C# 程序开始执行时,会自动创建主线程。使用 Thread 类创建的线程称为主线程的子线程。您可以使用 Thread 类的 CurrentThread 属性访问线程。
以下程序演示了主线程的执行 −
using System; using System.Threading; namespace MultithreadingApplication { class MainThreadProgram { static void Main(string[] args) { Thread th = Thread.CurrentThread; th.Name = "MainThread"; Console.WriteLine("This is {0}", th.Name); Console.ReadKey(); } } }
当编译并执行上述代码时,它会产生以下结果 -
This is MainThread
Thread 类的属性和方法
下表列出了 Thread 类的一些最常用的 属性 -
序号 | 属性 &说明 |
---|---|
1 | CurrentContext 获取线程当前执行的上下文。 |
2 | CurrentCulture 获取或设置当前线程的文化。 |
3 | CurrentPrinciple 获取或设置线程的当前主体(用于基于角色的安全性)。 |
4 | CurrentThread 获取当前正在运行的线程。 |
5 | CurrentUICulture 获取或设置资源管理器在运行时查找特定于文化的资源时使用的当前文化。 |
6 | ExecutionContext 获取一个 ExecutionContext 对象,该对象包含有关当前线程各种上下文的信息。 |
7 | IsAlive 获取指示当前线程执行状态的值。 |
8 | IsBackground 获取或设置一个值,指示线程是否为后台线程。 |
9 | IsThreadPoolThread 获取一个值,指示线程是否属于托管线程池。 |
10 | ManagedThreadId 获取当前托管线程的唯一标识符。 |
11 | Name 获取或设置线程的名称。 |
12 | Priority 获取或设置指示线程调度优先级的值。 |
13 | ThreadState 获取包含当前线程状态的值。 |
下表列出了Thread类的一些最常用方法类 −
序号 | 方法及说明 |
---|---|
1 | public void Abort() 在调用此方法的线程中引发 ThreadAbortException 异常,以开始终止线程的过程。调用此方法通常会终止线程。 |
2 | public static LocalDataStoreSlot AllocateDataSlot() 在所有线程上分配一个未命名的数据槽。为了获得更好的性能,请使用标有 ThreadStaticAttribute 属性的字段。 |
3 | public static LocalDataStoreSlot AllocateNamedDataSlot(string name) 在所有线程上分配一个命名的数据槽。为了获得更好的性能,请改用标有 ThreadStaticAttribute 属性的字段。 |
4 | public static void BeginCriticalRegion() 通知主机执行即将进入一个代码区域,在该区域,线程中止或未处理的异常的影响可能会危及应用程序域中的其他任务。 |
5 | public static void BeginThreadAffinity() 通知主机托管代码即将执行依赖于当前物理操作系统线程身份的指令。 |
6 | public static void EndCriticalRegion() 通知主机执行即将进入一个代码区域,在该区域内,线程中止或未处理的异常的影响仅限于当前任务。 |
7 | public static void EndThreadAffinity() 通知主机,托管代码已完成执行依赖于当前物理操作系统线程标识的指令。 |
8 | public static void FreeNamedDataSlot(string name) 为进程中的所有线程消除名称和槽之间的关联。为了获得更好的性能,请改用带有 ThreadStaticAttribute 属性标记的字段。 |
9 | public static Object GetData(LocalDataStoreSlot slot) 在当前线程的当前域内,从当前线程的指定槽中检索值。为了获得更好的性能,请改用标有 ThreadStaticAttribute 属性的字段。 |
10 | public static AppDomain GetDomain() 返回当前线程正在运行的当前域。 |
11 | public static AppDomain GetDomainID() 返回唯一的应用程序域标识符 |
12 | public static LocalDataStoreSlot GetNamedDataSlot(string name) 查找已命名的数据槽。为了获得更好的性能,请改用标有 ThreadStaticAttribute 属性的字段。 |
13 | public void Interrupt() 中断处于 WaitSleepJoin 线程状态的线程。 |
14 | public void Join() 阻塞调用线程,直到某个线程终止,同时继续执行标准 COM 和 SendMessage 消息传输。此方法有不同的重载形式。 |
15 | public static void MemoryBarrier() 按如下方式同步内存访问:执行当前线程的处理器无法以某种方式重新排序指令,即在调用 MemoryBarrier 之前的内存访问在调用 MemoryBarrier 之后的内存访问之后执行。 |
16 | public static void ResetAbort() 取消当前线程的中止请求。 |
17 | public static void SetData(LocalDataStoreSlot slot, Object data) 为当前正在运行的线程的当前域设置指定插槽中的数据。为了获得更好的性能,请改用标有 ThreadStaticAttribute 属性的字段。 |
18 | public void Start() 启动一个线程。 |
19 | public static void Sleep(int millisecondsTimeout) 使线程暂停一段时间。 |
20 | public static void SpinWait(int iterations) 使线程等待 iterations 参数定义的次数。 |
21 | public static byte VolatileRead(ref byte address) public static double VolatileRead(ref double address) public static int VolatileRead(ref int address) public static Object VolatileRead(ref Object address) 读取字段的值。该值是计算机中任何处理器写入的最新值,无论处理器数量或处理器缓存的状态如何。此方法有不同的重载形式。以上仅列出了部分重载形式。 |
22 | public static void VolatileWrite(ref byte address,byte value) public static void VolatileWrite(ref double address, double value) public static void VolatileWrite(ref int address, int value) public static void VolatileWrite(ref Object address, Object value) 立即将值写入字段,以便计算机中的所有处理器都可以看到该值。此方法有不同的重载形式。上面仅列出了部分重载形式。 |
23 | public static bool Yield() 使调用线程将执行权交给当前处理器上已准备好运行的另一个线程。操作系统将选择要交给的线程。 |
创建线程
通过扩展 Thread 类来创建线程。扩展的 Thread 类随后调用 Start() 方法来开始子线程的执行。
The following program demonstrates the concept −
using System; using System.Threading; namespace MultithreadingApplication { class ThreadCreationProgram { public static void CallToChildThread() { Console.WriteLine("Child thread starts"); } static void Main(string[] args) { ThreadStart childref = new ThreadStart(CallToChildThread); Console.WriteLine("In Main: Creating the Child thread"); Thread childThread = new Thread(childref); childThread.Start(); Console.ReadKey(); } } }
当编译并执行上述代码时,它会产生以下结果 -
In Main: Creating the Child thread Child thread starts
管理线程
Thread 类提供了多种管理线程的方法。
以下示例演示了如何使用 sleep() 方法使线程暂停一段特定的时间。
using System; using System.Threading; namespace MultithreadingApplication { class ThreadCreationProgram { public static void CallToChildThread() { Console.WriteLine("Child thread starts"); // 线程暂停 5000 毫秒 int sleepfor = 5000; Console.WriteLine("Child Thread Paused for {0} seconds", sleepfor / 1000); Thread.Sleep(sleepfor); Console.WriteLine("Child thread resumes"); } static void Main(string[] args) { ThreadStart childref = new ThreadStart(CallToChildThread); Console.WriteLine("In Main: Creating the Child thread"); Thread childThread = new Thread(childref); childThread.Start(); Console.ReadKey(); } } }
当编译并执行上述代码时,它会产生以下结果 -
In Main: Creating the Child thread Child thread starts Child Thread Paused for 5 seconds Child thread resumes
销毁线程
Abort() 方法用于销毁线程。
运行时通过抛出 ThreadAbortException 异常来中止线程。此异常无法捕获,控制权将转移到 finally 代码块(如果有)。
以下程序演示了此过程 -
using System; using System.Threading; namespace MultithreadingApplication { class ThreadCreationProgram { public static void CallToChildThread() { try { Console.WriteLine("Child thread starts"); // 做一些工作,比如数到 10 for (int counter = 0; counter <= 10; counter++) { Thread.Sleep(500); Console.WriteLine(counter); } Console.WriteLine("Child Thread Completed"); } catch (ThreadAbortException e) { Console.WriteLine("Thread Abort Exception"); } finally { Console.WriteLine("Couldn't catch the Thread Exception"); } } static void Main(string[] args) { ThreadStart childref = new ThreadStart(CallToChildThread); Console.WriteLine("In Main: Creating the Child thread"); Thread childThread = new Thread(childref); childThread.Start(); //停止主线程一段时间 Thread.Sleep(2000); //now abort the child Console.WriteLine("In Main: Aborting the Child thread"); childThread.Abort(); Console.ReadKey(); } } }
当编译并执行上述代码时,它会产生以下结果 -
In Main: Creating the Child thread Child thread starts 0 1 2 In Main: Aborting the Child thread Thread Abort Exception Couldn't catch the Thread Exception