厨房大理石台面的价格:SQLite开发应用：SQLite多线程写锁文件解决方案(C#)

来源：百度文库编辑：偶看新闻时间：2024/04/30 02:49:32

在sqlite编程中多线程同时写时会出现异常，我写了个类来解决这个问题。

思路很简单，就是在开始写操作时，记下写操作的托管线程id，表示目前有线程正在做写操作；其他线程来写时，需要先检测是否有进程正在做写操作，如果有就需要等待，等待到某一个配置的超时时间时，会抛出异常终止等待；如果没有则直接放行，此线程可以获得写锁。最后写操作执行完毕时需要释放锁。

下面是具体的代码：

SQLiteWriteLock
///

/// 用于在多线程访问sqlite时防止同步写导致锁文件
///
/// 使用方法：
/// using (SQLiteWriteLock sqliteLock = new SQLiteWriteLock(SQLite链接字符串))
/// {
/// //sqlite 写操作代码
/// }
///
/// 可以通过在配置文件appSettings节中添加设置 SQLiteWriteLockTimeout 的value值控制锁等待的超时时间，该值必须为正整数数字，单位为毫秒，
/// 默认的超时时间是1000ms
///

public sealed class SQLiteWriteLock : IDisposable
{
    #region 静态字段和属性
    const short WAIT_TIME = 5;
    static readonly object locker = new object();
    static Dictionary _dbThreadIdDict = new Dictionary();

    ///

    /// 获得写操作的超时时间，单位为毫秒，可以通过配置文件appSettings节中添加设置 SQLiteWriteLockTimeout 的value值控制锁等待的超时时间，该值必须为正整数数字，单位为毫秒
    /// 默认的超时时间是1000ms
    ///

    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
}

希望此文有用。

VB中操纵SQLite格式的数据库请问sqlite支不支持phpwind 和discuz!论坛？谁知道哪里有sqlite交流QQ群的，谢谢！！请问，sqlite如何从多张表中选择字段创建视图 SQlite是什么数据库？和access比起来好很多吗？ sqlite数据库被我不小心覆盖了,有没有办法恢复原来的数据? 怎么用asp来操作sqlite数据库，要求具体的完整例子怎么用vb来操作sqlite数据库，要求具体的完整例子 JACK开发电子商务应用应用开发的方法？ J2EE的应用开发 SQLServer2000应用开发实例教程什么是构件应用开发体系? 数据库应用系统开发简介 dsp2407开发板的应用，及原理煤焦油深加工新技术开发与应用电子商务应用系统的开发周期？ VC++开发应用系统的过程什么是windows程序应用开发工具 asp电子政务应用系统开发实例导航应用开发体系结构的类型有哪些？ EVC高级编程及其应用开发网络财务软件的开发与应用研究壳聚糖的开发与应用