在C#的多线程开发体系中,Thread类是最贴近操作系统线程的原生实现,它提供了对线程生命周期的直接控制能力,适合需要精细管理线程的场景。理解Thread的核心特性和使用规则,是掌握C#多线程编程的基础。

Thread的基础使用
使用Thread创建线程最核心的步骤是定义线程执行的方法,然后将方法委托传递给Thread构造函数,最后调用Start方法启动线程。无参数的线程方法可以直接使用ThreadStart委托,有参数的方法则使用ParameterizedThreadStart委托。
using System;
using System.Threading;
class Program
{
// 无参数线程方法
static void NoParamMethod()
{
Console.WriteLine("无参数线程执行,线程ID:" + Thread.CurrentThread.ManagedThreadId);
}
// 有参数线程方法,参数类型必须为object
static void WithParamMethod(object param)
{
string content = param as string;
Console.WriteLine("有参数线程执行,参数:" + content + ",线程ID:" + Thread.CurrentThread.ManagedThreadId);
}
static void Main()
{
// 创建无参数线程
Thread thread1 = new Thread(new ThreadStart(NoParamMethod));
thread1.Start();
// 创建有参数线程
Thread thread2 = new Thread(new ParameterizedThreadStart(WithParamMethod));
thread2.Start("测试参数");
// 等待子线程执行完成
thread1.Join();
thread2.Join();
Console.WriteLine("主线程执行完成");
}
}Thread的核心属性与状态管理
Thread类提供了多个属性用于查询和控制线程状态,常用的包括优先级、运行状态、是否为后台线程等。
- Priority:设置线程优先级,取值范围是ThreadPriority枚举,包含Lowest、BelowNormal、Normal、AboveNormal、Highest,优先级高的线程会获得更多的CPU时间片,但不代表一定先执行。
- IsBackground:设置是否为后台线程,后台线程不会阻止进程退出,而前台线程(默认)会直到所有前台线程执行完成,进程才会退出。
- ThreadState:获取线程当前的状态,包含Unstarted、Running、WaitSleepJoin、Stopped等状态,可用于判断线程是否执行完成。
using System;
using System.Threading;
class Program
{
static void TestMethod()
{
Thread.Sleep(2000);
Console.WriteLine("子线程执行完成");
}
static void Main()
{
Thread thread = new Thread(new ThreadStart(TestMethod));
// 设置为后台线程
thread.IsBackground = true;
// 设置优先级为最高
thread.Priority = ThreadPriority.Highest;
Console.WriteLine("启动前线程状态:" + thread.ThreadState);
thread.Start();
Console.WriteLine("启动后线程状态:" + thread.ThreadState);
// 主线程等待1秒
Thread.Sleep(1000);
Console.WriteLine("等待1秒后线程状态:" + thread.ThreadState);
// 等待子线程完成
thread.Join();
Console.WriteLine("完成后线程状态:" + thread.ThreadState);
}
}线程同步的常用方案
多个线程同时操作共享资源时,很容易出现资源竞争问题,比如两个线程同时修改同一个变量,可能导致数据不一致。这时候需要使用线程同步机制来保证同一时间只有一个线程操作共享资源。
lock关键字
lock是C#中最常用的同步方式,它通过一个共享的锁对象,保证代码块在同一时间只能被一个线程访问。注意锁对象必须是引用类型,且所有需要同步的线程必须使用同一个锁对象。
using System;
using System.Threading;
class Counter
{
private int count = 0;
// 锁对象,必须是引用类型
private readonly object lockObj = new object();
public void Increment()
{
// 加锁,同一时间只有一个线程能进入该代码块
lock (lockObj)
{
count++;
Console.WriteLine("当前计数:" + count + ",线程ID:" + Thread.CurrentThread.ManagedThreadId);
}
}
}
class Program
{
static void Main()
{
Counter counter = new Counter();
// 创建10个线程同时执行计数增加操作
Thread[] threads = new Thread[10];
for (int i = 0; i < 10; i++)
{
threads[i] = new Thread(new ThreadStart(counter.Increment));
threads[i].Start();
}
// 等待所有线程完成
foreach (Thread t in threads)
{
t.Join();
}
Console.WriteLine("所有线程执行完成");
}
}Monitor类
lock关键字本质上是Monitor类的语法糖,Monitor提供了更灵活的同步控制,比如可以尝试获取锁,或者设置获取锁的超时时间。
using System;
using System.Threading;
class Program
{
private static object lockObj = new object();
private static int sharedValue = 0;
static void ModifyValue()
{
// 尝试获取锁,最多等待500毫秒
if (Monitor.TryEnter(lockObj, 500))
{
try
{
sharedValue++;
Console.WriteLine("修改后的值:" + sharedValue);
}
finally
{
// 释放锁
Monitor.Exit(lockObj);
}
}
else
{
Console.WriteLine("获取锁超时,未修改值");
}
}
static void Main()
{
for (int i = 0; i < 5; i++)
{
new Thread(new ThreadStart(ModifyValue)).Start();
}
}
}Thread与线程池的差异
虽然Thread可以灵活控制线程,但是频繁创建和销毁Thread会带来较大的性能开销,因为每个Thread都对应操作系统的一个内核线程,创建成本很高。而线程池(ThreadPool)是预先创建好一组线程,需要执行任务时直接从池中获取,执行完成后归还到池中,避免了频繁创建销毁的开销。
| 对比项 | Thread | ThreadPool |
|---|---|---|
| 线程创建开销 | 大,每次创建都是新的内核线程 | 小,复用池中的线程 |
| 生命周期控制 | 可以精确控制启动、暂停、终止 | 由线程池管理,无法直接控制 |
| 适用场景 | 需要长时间运行、需要精细控制的任务 | 大量短时间、轻量的异步任务 |
| 参数传递 | 支持ParameterizedThreadStart传参 | 支持QueueUserWorkItem传参 |
使用Thread的注意事项
- 不要频繁创建和销毁Thread,对于大量短期任务优先使用线程池或者Task。
- 避免使用Thread.Abort方法终止线程,该方法会抛出ThreadAbortException,可能导致资源无法正确释放,建议使用标志位让线程主动退出。
- 锁对象不要使用public类型的对象,也不要使用this作为锁对象,避免外部代码意外获取锁导致死锁。
- 前台线程默认会阻止进程退出,如果不需要阻止进程退出,记得将线程设置为后台线程。
多线程编程的核心是平衡性能和数据安全,Thread作为最基础的线程实现,适合特定的需要精细控制的场景,大部分通用场景可以优先考虑更高级的Task或者并行库,减少手动管理线程的成本。