您的位置:首页 > 数据库

利用读写锁实现sqlite多线程写的问题

2018-02-24 16:25 253 查看
之前项目中利用sqlite存储解析后的数据,网上的资料并没有找到sqlite本身机制对于多线程如何支持,所以就利用每个线程一个库,最后在合并,今天看到读写锁SRWLOCK时,决定尝一下解决多线程写sqlite的问题
如愿解决:
    测试代码

    main函数中:sqlite3_open_v2("test.db",&m_db,SQLITE_OPEN_CREATE|SQLITE_OPEN_READWRITE,NULL);

int nret = sqlite3_exec(m_db,"create table tab1 (ID TEXT)",NULL,NULL,NULL);

InitializeSRWLock(&srwLock);
for (int i = 0 ; i < 10 ; i++)
{
_beginthreadex(NULL,0,WriteThreads,NULL,0,NULL);
}线程函数:unsigned WINAPI WriteThreads(void *pPM)
{
while(1)
{
Sleep(2000);
AcquireSRWLockExclusive(&srwLock);
printf("写线程\n");
char chsql[1024] = {0};
sprintf(chsql,"insert into tab1 values ('thread 0X%08X write 1')",GetCurrentThreadId());

int nret = sqlite3_exec(m_db,chsql,NULL,NULL,NULL);
if(nret != SQLITE_OK)
{
printf("================write error============\n");
}
ReleaseSRWLockExclusive(&srwLock);
}

return 0;
}结果展示:



内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: