构建下载线程池及队列 ，接收用户请求存mysql同时放入队列，线程池监听队列，启动下载线程，下载数据并保存导文件目录，同时更新mysql相应的请求，填充下载文件字段

好的，我理解您的问题是如何构建一个下载线程池及队列，接收用户请求存入 MySQL 并放入队列，然后线程池监听队列，启动下载线程，下载数据并保存到文件目录，同时更新 MySQL 相应的请求，填充下载文件字段。以下是一个简单的实现方式：

1. 首先，我们需要一个请求队列。对于 Python 来说，可以使用内置的 queue 模块来创建一个线程安全的队列：

import queue

q = queue.Queue()

2. 接下来，我们需要一个数据库来存储用户请求和下载文件的信息。这里我们使用 MySQL 数据库，可以使用 Python 的 PyMySQL 模块来进行操作：

import pymysql

db = pymysql.connect(host='localhost', user='user', password='password', db='database')
cursor = db.cursor()

3. 当用户发起下载请求时，我们可以将请求信息存入数据库，并将请求信息放入队列中：

def save_request_to_database(request):
    sql = "INSERT INTO requests (url, filename) VALUES (%s, %s)"
    cursor.execute(sql, (request['url'], request['filename']))
    db.commit()

def enqueue_request(request):
    save_request_to_database(request)
    q.put(request)

4. 接下来，我们需要一个下载线程池。Python 内置的 concurrent.futures 模块提供了 ThreadPoolExecutor 和 ProcessPoolExecutor 两个类来实现线程池和进程池。这里我们使用线程池，因为下载通常是 I/O 密集型任务，使用线程池可以更好地利用 CPU：

import concurrent.futures

executor = concurrent.futures.ThreadPoolExecutor(max_workers=10)

5. 线程池需要一个任务函数来执行任务。我们可以定义一个 download 函数来下载数据，并将下载的文件保存到文件目录中：

import requests

def download(request):
    url = request['url']
    filename = request['filename']
    response = requests.get(url)
    with open(filename, 'wb') as f:
        f.write(response.content)
    update_request_in_database(request, filename)

def update_request_in_database(request, filename):
    sql = "UPDATE requests SET downloaded_file=%s WHERE url=%s"
    cursor.execute(sql, (filename, request['url']))
    db.commit()

6. 最后，我们需要一个循环来监听队列，当有请求时，提交任务给线程池执行：

while True:
    request = q.get()
    executor.submit(download, request)

以上就是一个简单的实现方式，您可以根据自己的需求进行修改和优化。注意在实际使用中，要考虑线程安全、错误处理、日志记录等问题。