使用SQLite进行Python简单数据存储的线程安全解决方案

import sqlite3
import threading
 
# 创建数据库连接和锁
conn = sqlite3.connect('example.db', timeout=10)
lock = threading.Lock()
 
def query_data(query, params=()):
    with lock:
        cursor = conn.cursor()
        cursor.execute(query, params)
        return cursor.fetchall()
 
def insert_data(query, params=()):
    with lock:
        cursor = conn.cursor()
        cursor.execute(query, params)
        conn.commit()
 
# 使用示例
query = "SELECT * FROM some_table WHERE condition = ?"
params = ('value',)
data = query_data(query, params)
 
insert = "INSERT INTO some_table (column1, column2) VALUES (?, ?)"
insert_params = ('data1', 'data2')
insert_data(insert, insert_params)

这个代码示例展示了如何在Python中使用sqlite3和threading库来创建一个线程安全的数据库查询和插入函数。通过使用锁（lock），确保同时只有一个线程可以进行数据库操作，避免了并发时可能出现的数据不一致或锁冲突问题。这是一个简单的解决方案，适用于需要线程安全数据库交互的应用场景。