今天在做SQL并发UPDATE时遇到一个异常:(代码如下)
//Parallel 类可产生并发操作(即多线程)
Parallel.ForEach(topics, topic =>
{
//DBHelper是一个封装的数据库操作类,下面这行代码将执行UPDATE语句
DBHelper.Update(topic, "TopicID=" + topic.TopicID);
});
出现此问题的原因是,在SQLServer默认情况下,一条SQL语句就是一个事务。而在多线程同时UPDATE时,会同时产生多个事务,A事务等待B事务结束,B事务等待A事务结束,则造成了死锁。
解决方法:lock 加锁 (即:在多个线程同时访问 lock 代码区时,只允许一个线程进入,其他线程处于等待状态)
//声明静态只读锁对象
private static readonly object o = new object(); Parallel.ForEach(topics, topic =>
{
//加锁
lock (o)
{
//同一时刻仅能有一个线程进入
DBHelper.Update(topic, "TopicID=" + topic.TopicID);
}
});