如何在 C# 中处理线程隔离

Question

我正在开发一个实体框架中的多线程程序，其中我面临一个问题。我有一个多个数据库的列表，对于每个数据库我需要执行一些操作（插入/更新），目前我面临线程之间的竞争条件问题，其中我得到实体框架的错误。

异常：- 底层提供程序在打开时失败。

InnerException :- 连接没有关闭。连接的当前状态为正在连接。

我用过static readonly object Locker = new object();

lock (Locker)

但这会一个一个地执行线程。有什么方法可以一次生成所有线程，而不会出现实体框架错误，即在线程隔离中执行。

我的代码如下

var keyController = _empUnitOfWork.Repository<KeyController>()
                                        .Get(x => x.Type.Equals("X") && x.IsOnline).AsNoTracking().ToList();
        var taskList = new Task[keyController.Count];
        for (var i = 0; i < keyController.Count; i++)
        {
            var idx = i;
            var otherUnitOfWork = new TestUnitOfWork(_logger);
            otherUnitOfWork.SetSiteDbContext(_empUnitOfWork, keyController[idx].Id);
            taskList[idx] = Task.Factory.StartNew(() =>
            {
                 OtherMethodToBeExecutedOnMultipleThread(keyController[idx], otherUnitOfWork);
            });

        }
        // Wait for all tasks to complete.
        Task.WaitAll(taskList);

Answer 1

大家好，感谢您的回复， 我找到了一个解决方案，我现在为每个线程初始化新的数据库上下文。它按预期工作并且可以一次生成所有线程。