如何在peewee-orm中使用ThreadPoolExecutor处理数据库连接池？

from concurrent.futures import ThreadPoolExecutor
from peewee import MySQLDatabase, Model, Proxy

database_proxy = Proxy()  # 创建数据库代理

class BaseModel(Model):
    class Meta:
        database = database_proxy  # 设置模型的数据库连接

database = MySQLDatabase('database_name', user='username', password='password', host='host', port=3306)  # 创建数据库实例
database_proxy.initialize(database)  # 初始化数据库代理

executor = ThreadPoolExecutor(max_workers=10)  # 创建线程池，设置最大工作线程数

def execute_query(query):
    with database.connection_context():
        return query.execute()  # 执行数据库查询操作

query = BaseModel.select().where(BaseModel.field == value)  # 构建查询语句
future = executor.submit(execute_query, query)  # 提交任务给线程池
result = future.result()  # 获取任务执行结果