首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 多线程写SQLite3数据库，遇到数据库锁住的问题，问大侠们如何解决？

多线程写SQLite3数据库，遇到数据库锁住的问题，问大侠们如何解决？

时间：2010-12-27

来源：互联网

如果线程数过大，数据库会出现锁住的现象
代码如下：
  1. #!/usr/bin/env python
  2. #-*-coding:utf-8-*-
  3. # 多线程写入数据库测试


  6. # 导入模块
  7. import threading,sqlite3,sys
  8. from time import ctime,sleep


  11. class MyThread(threading.Thread):
  12.     ''' 线程模块 '''
  13.     def __init__(self,func,args,name=''):
  14.         threading.Thread.__init__(self) # 显式调用父类初始化
  15.         self.name=name
  16.         self.func=func
  17.         self.args=args
  18.     def getResult(self):
  19.         return self.res # 返回函数结果
  20.     def run(self):
  21.         print 'starting',self.name,'at:',ctime()
  22.         self.res=apply(self.func,self.args) # 函数结果
  23.         print self.name,'finished at:',ctime()
  24.       
  25. flag=1
  26. def putsql(threadname):
  27.     global flag
  28.     ''' 写入数据库 '''
  29.     while flag:
  30.         con=sqlite3.connect("F:/workspace/test/threadsql.db")
  31.         cur=con.cursor()
  32.         try:
  33.             cur.execute("insert into threadtest (id,name) values (NULL,?)",(threadname,))
  34.         except Exception as E:
  35.             print E
  36.             sleep(5)
  37.         con.commit()
  38.         cur.close()
  39.         con.close()
  40.         print threadname,'Doing'
  41.         #sleep(1)

  43. def setflag(keys):
  44.     global flag
  45.     ''' 捕获键盘输入 用于控制数据库线程退出 '''
  46.     while 1:
  47.         ch = sys.stdin.read(1)
  48.         print ch
  49.         if ch==keys:
  50.             flag=0
  51.             break

  53. def main():
  54.     threads=25
  55.     threadarr=[]
  56.    
  57.     # 放入捕获线程
  58.     t=MyThread(setflag,('q',),setflag.__name__)
  59.     threadarr.append(t)
  60.    
  61.     # 放入工作线程
  62.     for i in range(threads):
  63.         t=MyThread(putsql,(putsql.__name__+str(i),),putsql.__name__)
  64.         threadarr.append(t)
  65.    
  66.     # 启动所有线程
  67.     for i in range(len(threadarr)):
  68.         threadarr[i].start()
  69.    
  70.     for i in range(len(threadarr)):
  71.         threadarr[i].join()

  73.     print  'all DONE'
  74.    
  75. if __name__=='__main__':
  76.     main()
复制代码

作者: hlsd665   发布时间: 2010-12-27

本帖最后由 zhyo 于 2010-12-29 11:00 编辑

回复 hlsd665
好像SQLite是单用户数据库，不能同时有多个线程进行操作。

作者: zhyo   发布时间: 2010-12-29

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net