C#中lock关键字实现多线程数据同步的正确用法

多线程共享数据同步的需求背景

在许多应用程序场景中，我们需要同时操作某个数据或文件。例如，构建一个邮件接收网关时，系统需要为每个邮箱开启独立的接收线程从POP3服务器收取邮件，并将结果存入统一的FTP服务器。在此过程中，邮件存储必须按接收顺序连续编号，这就要求“获取当前编号”与“递增编号”这两个动作必须是原子性且互斥的。

如果多个线程同时执行递增操作，由于计算机底层将一句代码拆解为多步执行，极易产生竞态条件，导致编号重复或错乱。此时，引入锁机制成为必然选择。

错误示范：为何lock(this)会失效

为了实现线程安全的编号递增，许多开发者首先想到的是使用`lock`关键字。假设我们有一个类`EmailInfo`，其中包含静态变量作为编号：

class EmailInfo
{
    public static int CurrentNumber;
}

在单个线程中，取得并递增编号的逻辑如下：

_CurrentNumber = ++EmailInfo.CurrentNumber;

虽然这只是一行代码，但在运行时分为两步： 1. `EmailInfo.CurrentNumber`自增1。 2. 将新值返回赋给局部变量`_CurrentNumber`。

如果线程A执行了自增但尚未返回值，此时线程B也执行自增，随后A和B拿到的返回值相同，破坏了顺序递增的规则。

一种常见的直觉做法是使用`lock(this)`来保护这段代码：

lock(this)
{
    _CurrentNumber = ++EmailInfo.CurrentNumber;
}

问题所在：在实际业务中，我们为每个邮箱创建了不同的`EmailInfo`实例。`this`指向的是当前实例对象。因为不同邮箱对应不同的对象实例，线程A锁定的是“A实例”，线程B锁定的是“B实例”。它们之间并没有竞争同一个锁，因此无法起到同步作用，这就是为什么代码看似写了锁，实际却无效的原因。

解决方案：使用静态同步根对象

要让所有线程竞争同一把锁，必须让`lock`语句包裹住完全相同的对象引用。最标准且安全的做法是在类中定义一个静态的对象字段作为同步根（SyncRoot）。

第1步：定义静态同步对象

在`EmailInfo`类中添加一个私有的、只读的静态对象：

class EmailInfo
{
    // 所有线程共用此静态对象进行锁控制
    private static readonly object syncRoot = new object();
    
    public static int CurrentNumber;
}

推荐使用`private static readonly`修饰符，以防止外部代码误用该对象加锁，同时也避免了每次创建实例都重新分配内存的问题。

第2步：应用lock保护共享资源

在所有访问和修改`CurrentNumber`的代码块前，加上`lock(syncRoot)`：

lock (EmailInfo.syncRoot)
{
    _CurrentNumber = ++EmailInfo.CurrentNumber;
}

执行效果：此时，无论有多少个`EmailInfo`实例，`EmailInfo.syncRoot`在内存中只有一个地址。当线程A进入锁区域时，持有该全局唯一对象的锁；其他线程即使试图执行相同代码，也会被阻塞，直到线程A释放锁。这样就保证了编号递增的严格顺序和线程安全。

C# Lock关键字的核心注意事项

• 锁的对象一致性：锁的关键在于“共有一把钥匙”。如果是实例变量，需确保所有相关线程操作的是同一个实例；如果是共享资源，务必使用静态对象或单例模式对象作为锁。
• 避免锁定公共类型或字符串：不要使用`lock(typeof(MyClass))`或`lock("someString")`，因为其他不可预知的代码也可能锁定这些全局公共资源，引发死锁。
• 性能考量：锁的范围应尽可能小，仅包裹必要的临界区代码，以减少线程等待时间，提高并发性能。
• 替代方案：对于简单的计数器或累加操作，现代C#还可以考虑使用`Interlocked.Increment`等无锁原子操作，在特定场景下性能更优。

以上就是C#中利用lock关键字实现多线程数据同步的详细内容，更多关于C#进阶技巧与线程安全的资料请关注本站其它相关文章！