如何在python中实现跨线程共享数据库

import threading
import sqlite3

conn = sqlite3.connect('database.db')

conn.execute('''CREATE TABLE IF NOT EXISTS users
                (id INTEGER PRIMARY KEY AUTOINCREMENT,
                name TEXT NOT NULL,
                age INTEGER NOT NULL)''')

def thread_function():
    # 在线程中执行数据库操作
    conn.execute("INSERT INTO users (name, age) VALUES ('John', 25)")
    conn.commit()

thread = threading.Thread(target=thread_function)
thread.start()

conn.execute("SELECT * FROM users")
result = conn.fetchall()
for row in result:
    print(row)

import threading
import sqlite3

# 创建数据库连接
conn = sqlite3.connect('database.db')

# 创建数据库表
conn.execute('''CREATE TABLE IF NOT EXISTS users
                (id INTEGER PRIMARY KEY AUTOINCREMENT,
                name TEXT NOT NULL,
                age INTEGER NOT NULL)''')

# 定义线程函数
def thread_function():
    # 在线程中执行数据库操作
    conn.execute("INSERT INTO users (name, age) VALUES ('John', 25)")
    conn.commit()

# 创建线程并启动
thread = threading.Thread(target=thread_function)
thread.start()

# 主线程操作数据库
conn.execute("SELECT * FROM users")
result = conn.fetchall()
for row in result:
    print(row)

# 关闭数据库连接
conn.close()