关于linq to sql类线程同步问题

例如,下面一段代码,当两个线程同时访问时会出现各种由于线程不同步而导致的问题,比如什么DataReader已打开未关闭啊,已经添加了重复的键啊等等。

           /// <summary>
/// 当前数据上下文,非线程安全
/// </summary>
static AouUnionPayDataContext db = new AouUnionPayDataContext(connStr); /// <summary>
/// 此处是并发发生错误的方法,当两个线程访问时会出错
/// </summary>
/// <typeparam name="T">查找的实体对象类型</typeparam>
/// <param name="predicate">查找的条件,linq to sql语法</param>
/// <returns></returns>
public T GetSingle(Expression<Func<T, bool>> predicate)
{
return db.GetTable<T>().SingleOrDefault(predicate);
}

非线程安全

主要问题在于,多线程情况下同时访问db对象,拿到db对象执行GetTable<T>()方法会出错,相当于都在使用同一个数据库DataReader。这种情况是不允许的。

当项目中很多地方都使用了db此对象,而所有的db都只允许单一线程进行操作时,这时候在代码段头尾加上lock(db){}是不够的。

可以考虑将db封装为线程安全对象,如以下代码:

         /// <summary>
/// 当前数据上下文,非线程安全
/// </summary>
static AouUnionPayDataContext db = new AouUnionPayDataContext(connStr); /// <summary>
/// 线程安全的数据库访问对象
/// </summary>
protected static AouUnionPayDataContext db_safe
{
set
{
lock(db)
{
db = value;
}
}
get
{
lock(db)
{
return db;
}
}
} /// <summary>
/// 使用了线程安全对象
/// </summary>
/// <typeparam name="T">查找的实体对象类型</typeparam>
/// <param name="predicate">查找的条件,linq to sql语法</param>
/// <returns></returns>
public T GetSingle(Expression<Func<T, bool>> predicate)
{
return db_safe.GetTable<T>().SingleOrDefault(predicate);
}

线程安全封装

上一篇:Python天天美味(15) - Python正则表达式操作指南(re使用)(转)


下一篇:关于 spring MVC 配置自动扫描中 use-default-filters 属性