Linq to SQL多线程

Question

我正在构建一个需要我使用DataContext内部线程的应用程序。我的应用程序不断抛出InvalidOperationException的相似：

There is already an open DataReader associated with this Command which must be closed first

ExecuteReader requires an open and available Connection. The connection's current state is connecting

这些例外是间歇的。

这里是我的代码片段：

var repo = new Repository(); 
var entities = repo.GetAllEntities(); 
foreach (var entity in entities) 
{ 
    ThreadPool.QueueUserWorkItem(
     delegate 
     { 
      try 
      { 
       ProcessEntity(entity); 
      } 
      catch (Exception) 
      { 
       throw; 
      } 
     }); 
} 

我认为它可能有一些与从主线程传递一个实体的线程的错误似乎只要我试图访问扔财产entity。

任何人有任何想法，为什么发生这种情况，我如何解决它？

更新

这是我决定去：

var events = new Dictionary<int, AutoResetEvent>(); 
var repo = new Repository(); 
var entities = repo.GetAllEntities(); 
foreach (var entity in entities) 
{ 
    events.Add(entity.ID, new AutoResetEvent(false)); 
    ThreadPool.QueueUserWorkItem(
     delegate 
     { 
      var repo = new Repository(); 
      try 
      { 
       ProcessHierarchy(repo.GetEntity(entity.ID), ReportRange.Weekly); 
      } 
      catch (Exception) 
      { 
       throw; 
      } 
      finally 
      { 
       events[entity.ID].Set(); 
      } 
     }); 
} 

WaitHandle.WaitAll(events.Values.ToArray()); 

改进/建议表示欢迎，但这似乎已经完成了帽子戏法。

Answer 1

抛出异常，因为当一个前面的阅读器尚未关闭实体的某些属性，执行新的查询。您无法同时在数据上下文中执行多个查询。

作为解决方法，您可以“访问”您在ProcessEntity()中访问的属性，并使SQL在线程之前运行。

例如：

var repo = new Repository(); 
var entities = repo.GetAllEntities(); 
foreach (var entity in entities) 
{ 
    var localEntity = entity; // Verify the callback uses the correct instance 
    var entityCustomers = localEntity.Customers; 
    var entityOrders = localEntity.Orders; 
    var invoices = entityOrders.Invoices; 
    ThreadPool.QueueUserWorkItem(
     delegate 
     { 
      try 
      { 
       ProcessEntity(localEntity); 
      } 
      catch (Exception) 
      { 
       throw; 
      } 
     }); 
} 

此解决方案将执行仅在主线程和处理SQL将在其他线程来完成。由于所有查询都是在单线程中完成的，因此您可以省去一些效率。如果在ProcessEntity()中有很多逻辑并且查询不是很重，那么这个解决方案很好。

Answer 2

尝试建立新的线程里面的仓库，而不是通过它的。

Answer 3

请注意，SqlConnection实例不是线程安全的。你是否仍然拥有一个开放的读者。一般来说，从多个线程访问SqlConnection实例会导致不可预知的间歇性问题。

请参见：http://msdn.microsoft.com/en-us/library/system.data.sqlclient.sqlconnection.aspx

Answer 4

对我来说，解决办法是光速持久化框架，这是免费的，直到8元。每个线程创建单元。

http://www.mindscapehq.com/products/LightSpeed/default.aspx