python mysql多线程

import threading
import mysql.connector.pooling

# 创建线程安全的数据库连接池
db_config = {
    "host": "localhost",
    "user": "user",
    "password": "password",
    "database": "database"
}
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **db_config)

# 线程锁
lock = threading.Lock()

def thread_task():
    try:
        # 从连接池中获取连接
        conn = pool.get_connection()
        cursor = conn.cursor()
        
        # 使用锁保护共享资源
        with lock:
            cursor.execute("SELECT * FROM table")
            result = cursor.fetchall()
            print(result)
        
        cursor.close()
        conn.close()
    except Exception as e:
        print(f"Error: {e}")

# 创建多个线程
threads = []
for i in range(10):
    t = threading.Thread(target=thread_task)
    threads.append(t)
    t.start()

# 等待所有线程完成
for t in threads:
    t.join()

# 增加连接池的大小
pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=10, **db_config)

# 使用超时机制
with lock:
    try:
        cursor.execute("SELECT * FROM table")
        result = cursor.fetchall()
        print(result)
    except mysql.connector.errors.OperationalError as e:
        if e.errno == 1205:  # 死锁错误
            print("Deadlock detected, retrying...")
            continue