C# - 多线程


线程被定义为程序的执行路径。每个线程定义一个独特的控制流。如果您的应用程序涉及复杂且耗时的操作,那么设置不同的执行路径或线程通常很有帮助,每个线程执行特定的作业。

线程是轻量级的进程。使用线程的一个常见示例是现代操作系统实现并发编程。线程的使用可以节省 CPU 周期的浪费并提高应用程序的效率。

到目前为止,我们编写的程序中单个线程作为单个进程运行,该进程是应用程序的运行实例。但是,通过这种方式,应用程序一次可以执行一项作业。为了使其一次执行多个任务,可以将其划分为更小的线程。

线程生命周期

线程的生命周期从 System.Threading.Thread 类的对象创建时开始,到线程终止或完成执行时结束。

以下是线程生命周期中的各种状态 -

  • 未启动状态- 这是创建线程实例但未调用 Start 方法的情况。

  • 就绪状态- 这是线程准备好运行并等待 CPU 周期的情况。

  • 不可运行状态- 线程不可执行,当

    • sleep方法已被调用
    • 等待方法已被调用
    • 被 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

当前上下文

获取线程正在执行的当前上下文。

2

当代文化

获取或设置当前线程的区域性。

3

现行原则

获取或设置线程的当前主体(用于基于角色的安全性)。

4

当前线程

获取当前正在运行的线程。

5

当前的UI文化

获取或设置资源管理器用于在运行时查找特定于区域性的资源的当前区域性。

6

执行上下文

获取一个 ExecutionContext 对象,该对象包含有关当前线程的各种上下文的信息。

7

活着

获取一个指示当前线程执行状态的值。

8

是背景

获取或设置一个值,该值指示线程是否为后台线程。

9

是线程池线程

获取一个值,该值指示线程是否属于托管线程池。

10

托管线程ID

获取当前托管线程的唯一标识符。

11

姓名

获取或设置线程的名称。

12

优先事项

获取或设置一个指示线程的调度优先级的值。

13

线程状态

获取包含当前线程状态的值。

下表显示了Thread类的一些最常用的方法-

先生。 方法及说明
1

公共无效中止()

在调用它的线程中引发 ThreadAbortException,以开始终止线程的过程。调用该方法通常会终止线程。

2

公共静态 LocalDataStoreSlot AllocateDataSlot()

在所有线程上分配未命名的数据槽。为了获得更好的性能,请改用使用 ThreadStaticAttribute 属性标记的字段。

3

公共静态 LocalDataStoreSlot AllocateNamedDataSlot(字符串名称)

在所有线程上分配命名数据槽。为了获得更好的性能,请改用使用 ThreadStaticAttribute 属性标记的字段。

4

公共静态无效BeginCriticalRegion()

通知主机执行即将进入一个代码区域,其中线程中止或未处理的异常的影响可能会危及应用程序域中的其他任务。

5

公共静态无效BeginThreadAffinity()

通知主机托管代码即将执行依赖于当前物理操作系统线程标识的指令。

6

公共静态无效 EndCriticalRegion()

通知主机执行即将进入代码区域,其中线程中止或未处理异常的影响仅限于当前任务。

7

公共静态无效EndThreadAffinity()

通知主机托管代码已完成执行依赖于当前物理操作系统线程标识的指令。

8

公共静态无效FreeNamedDataSlot(字符串名称)

对于进程中的所有线程,消除名称和槽之间的关联。为了获得更好的性能,请改用使用 ThreadStaticAttribute 属性标记的字段。

9

公共静态对象 GetData(LocalDataStoreSlot 插槽)

从当前线程的当前域内的当前线程上的指定槽中检索值。为了获得更好的性能,请改用使用 ThreadStaticAttribute 属性标记的字段。

10

公共静态 AppDomain GetDomain()

返回当前线程正在其中运行的当前域。

11

公共静态AppDomain GetDomainID()

返回唯一的应用程序域标识符

12

公共静态 LocalDataStoreSlot GetNamedDataSlot(字符串名称)

查找指定的数据槽。为了获得更好的性能,请改用使用 ThreadStaticAttribute 属性标记的字段。

13

公共无效中断()

中断处于 WaitSleepJoin 线程状态的线程。

14

公共无效加入()

阻止调用线程直到线程终止,同时继续执行标准 COM 和 SendMessage 泵送。该方法有不同的重载形式。

15

公共静态无效MemoryBarrier()

按如下方式同步内存访问:执行当前线程的处理器不能以这样的方式重新排序指令:调用 MemoryBarrier 之前的内存访问在调用 MemoryBarrier 之后的内存访问之后执行。

16

公共静态无效ResetAbort()

取消当前线程请求的中止。

17 号

公共静态无效SetData(LocalDataStoreSlot插槽,对象数据)

为当前正在运行的线程的当前域设置指定槽中的数据。为了获得更好的性能,请改用标有 ThreadStaticAttribute 属性的字段。

18

公共无效开始()

启动一个线程。

19

公共静态无效睡眠(int毫秒超时)

使线程暂停一段时间。

20

公共静态无效SpinWait(int迭代)

使线程等待由iterations参数定义的次数

21

公共静态字节VolatileRead(参考字节地址)

public static double VolatileRead(ref 双地址)

public static int VolatileRead(ref int 地址)

public static Object VolatileRead(ref 对象地址)

读取字段的值。该值是计算机中任何处理器最新写入的值,无论处理器的数量或处理器缓存的状态如何。该方法有不同的重载形式。上面只给出了一些。

22

公共静态无效VolatileWrite(引用字节地址,字节值)

公共静态无效VolatileWrite(引用双地址,双值)

公共静态无效VolatileWrite(引用int地址,int值)

public static void VolatileWrite(ref 对象地址,对象值)

立即将值写入字段,以便该值对计算机中的所有处理器都可见。该方法有不同的重载形式。上面只给出了一些。

23

公共静态 bool Yield()

导致调用线程将执行让步给准备在当前处理器上运行的另一个线程。操作系统选择要屈服的线程。

创建线程

线程是通过扩展 Thread 类来创建的。然后,扩展的 Thread 类调用Start()方法来开始子线程执行。

以下程序演示了这个概念 -

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");
         
         // the thread is paused for 5000 milliseconds
         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");
            
            // do some work, like counting to 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();
         
         //stop the main thread for some time
         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