在sqlite编程中多线程同时写时会出现异常,我写了个类来解决这个问题。
思路很简单,就是在开始写操作时,记下写操作的托管线程id,表示目前有线程正在做写操作;其他线程来写时,需要先检测是否有进程正在做写操作,如果有就需要等待,等待到某一个配置的超时时间时,会抛出异常终止等待;如果没有则直接放行,此线程可以获得写锁。最后写操作执行完毕时需要释放锁。
下面是具体的代码:
<!---->/// <summary>
/// 用于在多线程访问sqlite时防止同步写导致锁文件
///
/// 使用方法:
/// using (SQLiteWriteLock sqliteLock = new SQLiteWriteLock(SQLite链接字符串))
/// {
/// //sqlite 写操作代码
/// }
///
/// 可以通过在配置文件appSettings节中添加设置 SQLiteWriteLockTimeout 的value值控制锁等待的超时时间,该值必须为正整数数字,单位为毫秒,
/// 默认的超时时间是1000ms
/// </summary>
public sealed class SQLiteWriteLock : IDisposable
{
#region 静态字段和属性
const short WAIT_TIME = 5;
static readonly object locker = new object();
static Dictionary<string, int> _dbThreadIdDict = new Dictionary<string, int>();
/// <summary>
/// 获得写操作的超时时间,单位为毫秒,可以通过配置文件appSettings节中添加设置 SQLiteWriteLockTimeout 的value值控制锁等待的超时时间,该值必须为正整数数字,单位为毫秒
/// 默认的超时时间是1000ms
/// </summary>
public static int SQLiteWriteLockTimeout
{
get
{
string configValule = ConfigurationManager.AppSettings["SQLiteWriteLockTimeout"];
if (!string.IsNullOrEmpty(configValule))
{
return int.Parse(configValule);
}
return 1000;
}
}
#endregion
private readonly string _connString;
//隐藏无参构造函数
private SQLiteWriteLock() { }
public SQLiteWriteLock(string connString)
{
_connString = connString;
AcquireWriteLock();
}
#region 私有方法
private void AcquireWriteLock()
{
int threadId = Thread.CurrentThread.ManagedThreadId;
int waitTimes = 0;
while (_dbThreadIdDict.ContainsKey(_connString) && _dbThreadIdDict[_connString] != threadId)
{
Thread.Sleep(WAIT_TIME);
waitTimes += WAIT_TIME;
#if DEBUG
Console.WriteLine(_connString + " wait for " + waitTimes + " ms");
#endif
if (waitTimes > SQLiteWriteLockTimeout)
{
throw new TimeoutException("SQLite等待写操作超时");
}
}
lock (locker)
{
if (!_dbThreadIdDict.ContainsKey(_connString))
_dbThreadIdDict.Add(_connString, threadId);
}
}
private void ReleaseWriteLock()
{
lock (locker)
{
if (_dbThreadIdDict.ContainsKey(_connString))
{
_dbThreadIdDict.Remove(_connString);
}
}
}
#endregion
#region IDisposable 成员
public void Dispose()
{
ReleaseWriteLock();
}
#endregion
}
希望此文有用。
分享到:
相关推荐
多线程读写sqlite数据库,同步锁,计时测试读写性能,
总结了一下Qt中sqlite多线程操作遇到的几个问题,希望能对有需要的朋友一点帮助
SQLite是文件级别的数据库,其锁也是文件级别的:多个线程可以同时读,但是同时只能有一个线程写。Android提供了SqliteOpenHelper类,加入Java的锁机制以便调用。但在C#中未提供类似功能。 作者利用读写锁...
我们可以得知SQLite是文件级别的锁:多个线程可以同时读,但是同时只能有一个线程写。Android提供了SqliteOpenHelper类,加入Java的锁机制以便调用。如果多线程同时读写(这里的指不同的线程用使用的是不同的Helper...
多进程写sqlite数据库解决互斥的方案,当然代码也顺便处理了多线程写数据库的问题。
Qt自带了sqlite的驱动,也有各种文件的读写操作,用起来很是方便,这里仅仅是做了一个简单的封装,方便多个数据库和多个文件的操作。
linux sqlite多线程读写源代码
sqlite数据库,用c++封装类,以及源码实现的对sqlite数据库封装类的操作。同时有boost多线程对sqlite数据库进行操作。 真是学习居家的好例子。。。。
#SQLITE_配置_串行化 启用所有互斥锁,多个线程都可以使用相同的连接和准备的SQL语句。当然还有一些配置我没有封装完,基本是些内存方面的。另外编译了各种加密算法的dll,分别放在了不同的文件夹。AES128、AES256、...
SQLite 数据库加密的一种解决方案,对SQLite这种小型的数据库也可以进行加密
Sqlite解决database locked问题
解决sqlite3 databaselocked 问题的代码实例,比较有参考价值。
多线程使用FMDB操作sqlite数据库 对应博客链接http://blog.csdn.net/liuyinghui523/article/details/79483963
本篇文章是对Sqlite多线程入库的问题进行了详细的分析介绍,需要的朋友参考下