跳转到主内容
新派编程网 - 新潮编程理念,全新技术课堂!

.NET怎么实现多线程编程中的线程同步_多线程同步实现方案

.NET多线程同步机制包括:1. lock用于临界区保护,语法简洁但不支持超时;2. Monitor提供更细粒度控制,支持超时和线程通信;3. Mutex实现跨进程同步,性能较低;4. SemaphoreSlim限制并发数,适合单进程内使用;5. ReaderWriterLockSlim适用于读多写少场景;6. Interlocked提供原子操作,性能高;7. volatile保证变量可见性,不保证原子性。应根据场景选择合适方式以确保线程安全并避免性能瓶颈。 在 .NET 多线程编程中,多个线程同时访问共享资源时容易引发数据不一致、竞态条件等问题。为保证程序的正确性和稳定性,必须使用线程 同步机制 来协调线程之间的执行顺序和资源访问。.NET 提供了多种线程同步方案,可以根据不同场景选择合适的方式。 1. lock 关键字(Monitor) lock 是最常用的线程同步方式,它基于 Monitor 类实现,用于确保同一时间只有一个线程可以进入临界区。 说明: lock 只能作用于引用类型对象,通常建议使用私有的、只用于锁的对象。 示例代码:
private static readonly object _lockObj = new object(); private static int _counter = 0; public static void Increment() { lock (_lockObj) { _counter++; } }
优点:语法简洁,自动处理 Monitor.Enter 和 Monitor.Exit,避免死锁风险。缺点:不能跨进程,且不支持超时控制。 2. Monitor 类(更灵活的锁控制) lock 是 Monitor 的语法糖,Monitor 提供了更细粒度的控制,如 TryEnter 支持超时、中断等。 常用方法: Monitor.Enter(obj) / Monitor.Exit(obj) Monitor.TryEnter(obj, timeout):尝试获取锁,指定超时时间 Monitor.Wait() / Monitor.Pulse():实现线程间通信 示例:带超时的锁尝试
if (Monitor.TryEnter(_lockObj, TimeSpan.FromSeconds(1))) { try { _counter++; } finally { Monitor.Exit(_lockObj); } } else { // 获取锁失败,处理超时逻辑 }
3. Mutex(跨进程同步) Mutex 是一个系统级同步原语,支持跨进程的线程同步,适合需要在多个应用程序之间协调资源访问的场景。 示例: PHP数据库链接类(PDO+Access) PHP数据库链接类(PDO+Access) 下载
using (var mutex = new Mutex(false, "Global\MyAppMutex")) { if (mutex.WaitOne(TimeSpan.FromSeconds(3))) { try { // 执行独占操作 } finally { mutex.ReleaseMutex(); } } }
注意:Mutex 性能低于 lock,仅在需要跨进程同步时使用。 4. Semaphore 和 SemaphoreSlim 信号量用于限制同时访问某一资源的线程数量,适合控制并发数(如数据库连接池)。 Semaphore :基于内核对象,支持跨进程,性能较低 SemaphoreSlim :用户模式,轻量高效,推荐在单进程内使用 示例:
private static SemaphoreSlim _semaphore = new SemaphoreSlim(3, 3); // 最多3个线程 public static async Task AccessResourceAsync() { await _semaphore.WaitAsync(); try { // 模拟工作 await Task.Delay(1000); } finally { _semaphore.Release(); } }
5. ReaderWriterLockSlim(读写锁) 适用于读多写少的场景。允许多个读线程同时访问,但写线程独占资源。 示例:
private static ReaderWriterLockSlim _rwLock = new ReaderWriterLockSlim(); public static int Read() { _rwLock.EnterReadLock(); try { return _counter; } finally { _rwLock.ExitReadLock(); } } public static void Write(int value) { _rwLock.EnterWriteLock(); try { _counter = value; } finally { _rwLock.ExitWriteLock(); } }
注意:避免死锁,确保每次进入锁后都正确退出。 6. Interlocked 类(原子操作) 用于对简单变量进行原子操作,如递增、交换、比较并交换等,性能极高,适合无锁编程场景。 示例:
private static int _flag = 0; public static bool SetFlag() { return Interlocked.CompareExchange(ref _flag, 1, 0) == 0; }
常用方法:Interlocked.Increment、Add、Read、CompareExchange 等。 7. volatile 关键字(可见性保障) 确保字段的读写直接从主内存进行,不被缓存在寄存器或 CPU 缓存中,保证变量的“可见性”。 适用场景:标志位检测。
private static volatile bool _shouldStop = false;
注意:volatile 不保证原子性,仅解决内存可见问题。 总结与选择建议 根据实际需求选择合适的同步机制: 普通临界区保护 → 使用 lock 需要超时或更细控制 → 使用 Monitor 跨进程同步 → 使用 Mutex 限制并发数 → 使用 SemaphoreSlim 读多写少 → 使用 ReaderWriterLockSlim 计数、标志位原子操作 → 使用 Interlocked 或 volatile 基本上就这些。合理使用这些机制,既能保证线程安全,又能避免 性能瓶颈 。不复杂但容易忽略细节,比如锁对象的选择、异常时释放锁、死锁预防等。

相关文章