并行环境数据不同步，如何确保指定ConcurrentBag代码单线程执行？

要让这段涉及ConcurrentBag的操作完全由单个线程执行，最直接且可靠的方式是使用排他锁（lock）来同步这段代码块。虽然ConcurrentBag本身是线程安全的集合，但你这里的操作是一组非原子的组合操作（获取最后一个元素、过滤集合、添加到另一个集合），这些步骤单独安全，但放在一起就会因为多线程并发修改导致数据不一致。

具体实现步骤： #

1. 首先定义一个专门的私有锁对象（不要直接锁AdminSites本身，避免和其他可能的锁操作冲突）：

private readonly object _adminSitesLock = new object();

2. 把你需要单线程执行的代码包裹在lock块中：

// 确保这段代码仅由单个线程执行
lock (_adminSitesLock)
{
    ConcurrentBag<string> AdminSites = new ConcurrentBag<string>();
    AdminSites.AddRangeCustom(OrganizationNavigatorHolder.Instance.GetElementIDList(filter));
    
    ancestorsForAdminSite = new ConcurrentBag<string>();
    string currentElementsAdminSite = AdminSites.ElementAtOrDefault(AdminSites.Count - 1);
    ancestorsForAdminSite.AddRangeCustom(AdminSites.Where(a => a != currentElementsAdminSite).ToList());
}

为什么这能解决问题？ #

• lock语句会保证同一时间只有一个线程能进入代码块，其他线程会等待直到锁被释放。
• 这样就避免了在执行"获取最后一个元素"和"过滤集合"这两步之间，其他线程修改AdminSites的内容，确保整个操作序列的原子性。

其他可选方案（如果需要更灵活的控制）： #

• SemaphoreSlim：如果是在.NET Core/.NET 5+环境中，可以用SemaphoreSlim(1, 1)来实现排他访问，用法和lock类似：

private readonly SemaphoreSlim _adminSitesSemaphore = new SemaphoreSlim(1, 1);

// 使用时
await _adminSitesSemaphore.WaitAsync();
try
{
    // 你的代码块
}
finally
{
    _adminSitesSemaphore.Release();
}

这种方式支持异步场景，如果你这段代码在异步方法里，用这个会更合适。

• Monitor类：lock本质上是Monitor.Enter和Monitor.Exit的语法糖，你也可以手动使用Monitor来实现，但lock更简洁易读。

注意点： #

• 锁对象要定义为类级别的私有字段，确保所有需要同步的线程都使用同一个锁对象。
• 尽量缩小锁的范围，只包裹需要同步的代码，避免影响其他无关操作的性能。

内容的提问来源于stack exchange，提问作者Taranbirbajwa Singh