使用Linq to SQL进行多线程处理

Question

由于最初的线程(使用Linq to SQL的多线程)已经变得很老了,我以为我会在类似的主题上发布另一个问题.考虑一种场景,其中DomainService公开了许多方法来从SQL Server数据库中检索数据.显然,在多用户场景中,同时有多个请求进入,人们不得不期望this.DataContext并行使用,开发人员无需控制或额外的工作来处理这些多个请求.那么,如果我将顺序的LINQ查询放入Parallel.Invoke()中,那么所有的地狱都会破裂,我得到的是"已经有一个与此命令关联的开放DataReader,必须首先关闭它".错误......？

为了演示,这有效:

List<Data> retVal = new List<Data>();

retVal.AddRange(this.DataContext.Table1.Where(w=>w.A==1).Select(s=>new Data{f1=s.D}).ToList());
retVal.AddRange(this.DataContext.Table1.Where(w=>w.B==2).Select(s=>new Data{f1=s.D}).ToList());
retVal.AddRange(this.DataContext.Table1.Where(w=>w.C==3).Select(s=>new Data{f1=s.D}).ToList());

......但这不是:

List<Data> retVal = new List<Data>();
Parallel.Invoke(
()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.A==1).Select(s=>new Data{f1=s.D}).ToList()),
()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.B==2).Select(s=>new Data{f1=s.D}).ToList()),
()=>retVal.AddRange(this.DataContext.Table1.Where(w=>w.C==3).Select(s=>new Data{f1=s.D})).ToList());

不要介意List不是线程安全的,因为错误来自SQL数据连接.

任何见解和解释将不胜感激.

Answer 1

首先,澄清一下,这个问题与多线程而不是多用户有关.在多用户场景中,每个用户都有自己的DataContext实例,避免了共享实例周围的线程问题.

并行示例失败,因为DataContext它不是一个线程安全的对象; 它希望由单个线程使用,而不是由许多并行使用.这是与数据读取器相关的异常,因为DataContext它的连接打开,当您尝试并行执行第二个语句时,使用数据读取器读取.

如果您尝试SqlConnection在没有任何序列化技术的情况下跨多个线程使用一个实例,那么同样的问题就会很明显.

Answer 2

你不应该分享DataContext跨线程.它本质上是不安全的.另外,DataContexts意味着每单位工作使用一个(即,每个对话一个).每个请求都应被视为不同的对话,并应以独特的方式回答DataContext.