Python如何在异步环境下运行多个线程？

Python在异步环境下，想要同时运行多个线程需要使用asyncio模块中的协程（coroutine）来实现。通过使用asyncio的run_in_executor函数，可以将需要在子线程中运行的函数变成一个协程对象，在异步环境下进行调用。

import asyncio
import concurrent.futures
from typing import Any, Callable


async def run_in_thread_pool(func: Callable[..., Any], *args: Any) -> Any:
    loop = asyncio.get_running_loop()
    with concurrent.futures.ThreadPoolExecutor() as pool:
        return await loop.run_in_executor(pool, func, *args)

async def download_file(url: str, filename: str) -> None:
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as response:
            content = await response.read()
            await run_in_thread_pool(write_to_file, content, filename)

def write_to_file(content: bytes, filename: str) -> None:
    with open(filename, 'wb') as file:
        file.write(content)

async def main():
    await asyncio.gather(download_file('http://example.com/image.jpg', 'image.jpg'),
                         download_file('http://example.com/data.csv', 'data.csv'))

asyncio.run(main())

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com