Python异步函数循环+返回参数

import asyncio

async def fetch_data(url):
    print(f"开始获取数据: {url}")
    await asyncio.sleep(2)  # 模拟网络请求延迟
    print(f"数据获取完成: {url}")
    return f"数据: {url}"

async def main():
    urls = ["url1", "url2", "url3"]
    tasks = [fetch_data(url) for url in urls]
    results = await asyncio.gather(*tasks)
    print(results)

# 运行事件循环
asyncio.run(main())

results = await asyncio.gather(*tasks, return_exceptions=True)
for result in results:
    if isinstance(result, Exception):
        print(f"发生异常: {result}")
    else:
        print(result)

import concurrent.futures

def sync_function():
    # 同步代码
    pass

async def async_function():
    loop = asyncio.get_running_loop()
    with concurrent.futures.ThreadPoolExecutor() as pool:
        result = await loop.run_in_executor(pool, sync_function)
        return result