SqlConnection with Parallel programming



这是我现有的代码,它将一些数据保存到几个表中

using (SqlConnection conn = new SqlConnection("myConnString"))
{
   DoWork1(conn);
   DoWork2(conc);
   DoWork3(conn);
}

为了加快我的代码速度,所以我尝试获得 .net TPL 支持,我重新挂起了我的代码,如下所示

using (SqlConnection conn = new SqlConnection("myConnString"))
{
   ParallelOptions pw = new ParallelOptions();
   pw.MaxDegreeOfParallelism = Environment.ProcessorCount;
   Parallel.Invoke(pw,()=> DoWork1(conn),()=> DoWork2(conc),()=> DoWork3(conn));
} 

但这给我的数据访问层中的 ExecuteNonQuery() 方法抛出了一个内部连接致命错误异常。我的并行方法有错吗?

嗯,有一些方法可以使用 MARS 来工作 - 但我建议采用不同的方法。(我不知道 MARS 是否支持跨多个线程使用相同的连接,即使它允许多个并发操作。

与其尝试在所有并行任务中重用一个连接,不如让每个任务为自己打开(和关闭)一个连接,并让连接池处理效率方面。无论是否使用并行性,这都是 .NET 中的一般最佳做法:打开连接,执行一些工作,关闭连接。

我没有

评论的声誉,但似乎我可以回答。这有点奇怪无论如何,我的评论是临时表是每个连接的,因此打开新连接意味着您无法看到其他任务创建的临时表。

全局临时表可能是答案,但您必须a) 使用单个全局临时表并使用某些键对数据进行分区b) 使用唯一命名的表,这意味着动态 SQL

真的有点乱

最新更新