sqlite3 多线程和锁 ，优化插入速度及性能优化

在使用SQLite3进行多线程插入时，为了避免数据竞争和死锁，可以使用数据库连接的串行化，即一次只允许一个线程访问数据库。另外，可以使用事务来提高插入的效率。

import sqlite3
import threading
 
def insert_data(db_path, data):
    # 使用串行化的数据库连接
    conn = sqlite3.connect(db_path, isolation_level=None)
    cursor = conn.cursor()
 
    # 开始事务
    cursor.execute("BEGIN TRANSACTION;")
 
    for row in data:
        cursor.execute("INSERT INTO table_name (column1, column2) VALUES (?, ?)", row)
 
    # 提交事务
    cursor.execute("COMMIT;")
    conn.close()
 
# 假设data_list包含了要插入的数据列表
data_list = [[row1], [row2], ...]
 
# 创建线程
threads = [threading.Thread(target=insert_data, args=(db_path, data)) for data in data_list]
 
# 启动线程
for t in threads:
    t.start()
 
# 等待所有线程完成
for t in threads:
    t.join()

在这个例子中，每个线程都会使用串行化的数据库连接，并在插入数据时使用事务来提高效率。通过开始事务，然后进行插入操作，最后提交事务，可以减少数据库的I/O操作，从而提高插入的速度。