为什么我的多线程 API 仍然很慢？

from playwright.async_api import async_playwrightimport asyncioasync def search_with_playwright(search_text: str, book_id: str):    async with async_playwright() as p:        browser = await p.chromium.launch(headless=true)        page = await browser.new_page()        book_id = book_id.replace("-1", "")        book_url = f"http://localhost:8002/book/{book_id}"        await page.goto(book_url)        await page.fill("#searchinput", search_text)        await page.click("#searchbutton")        await page.wait_for_selector("#searchresults")        search_results = await page.evaluate('''            () => {                let results = [];                document.queryselectorall("#searchresults ul li").foreach(item => {                    let excerptelement = item.queryselector("strong:nth-of-type(1)");                    let cfielement = item.queryselector("strong:nth-of-type(2)");                    if (excerptelement && cfielement) {                        let excerpt = excerptelement.nextsibling ? excerptelement.nextsibling.nodevalue.trim() : "";                        let cfi = cfielement.nextsibling ? cfielement.nextsibling.nodevalue.trim() : "";                        results.push({ excerpt, cfi });                    }                });                return results;            }        ''')        await browser.close()        return search_results

async def query_mongo(query: str, id: str):    query_vector = generate_embedding(query)    results = db[id].aggregate([        {            "$vectorSearch": {                "queryVector": query_vector,                "path": "embedding",                "numCandidates": 2100,                "limit": 50,                "index": id            }        }    ])    # Helper function for processing each document    def process_document(document):        try:            chunk = document["chunk"]            chapter = document["chapter"]            number = document["chapter_number"]            book_id = id            results = asyncio.run(search_with_playwright(chunk, book_id))            return {                "content": chunk,                "chapter": chapter,                "number": number,                "results": results,            }        except Exception as e:            print(f"Error processing document: {e}")            return None    # Using ThreadPoolExecutor for concurrency    all_data = []    with ThreadPoolExecutor() as executor:        futures = {executor.submit(process_document, doc): doc for doc in results}        for future in as_completed(futures):            try:                result = future.result()                if result:  # Append result if it's not None                    all_data.append(result)            except Exception as e:                print(f"Error in future processing: {e}")    return all_data