最近想用多线程来提高我的代码的执行效率,但是因为其中涉及到数据库的读写,为了数据库连接的线程安全,所以在网上冲浪后决定使用连接池的方式来取代之前普通数据库连接的方式。有兴趣的同学可以移步:Python 使用DBUtils 创建连接池解决多线程中连接丢失的问题
但是在使用多线程操作数据库连接池的过程中碰到下面这个问题
AttributeError: 'NoneType' object has no attribute 'read'
推测问题是,多线程操作数据库连接的时候,相互交叉释放了其他线程的连接。
解决方案是在获取数据库连接时加锁,查询完毕后释放锁
import threading lock = threading.Lock() lock.acquire() conn = pool.getConn() cur = conn.cursor() cur.execute(sql) rows = cur.fetchall() lock.release()