• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10

import asyncioasyncdefgreet(name):# async 关键字定义一个协程print(f"Hello, {name}!")await asyncio.sleep(1)  # 模拟耗时操作print(f"Goodbye, {name}!")# 运行协程asyncio.run(greet("Alice"))

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10

asyncdefmain():# 创建多个协程任务    task1 = asyncio.create_task(greet("Alice"))    task2 = asyncio.create_task(greet("Bob"))# 等待所有任务完成await asyncio.gather(task1, task2)# 启动事件循环asyncio.run(main())

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9
• 10
• 11
• 12
• 13
• 14
• 15
• 16
• 17
• 18
• 19
• 20
• 21
• 22
• 23
• 24

import asyncioimport aiohttpimport timeasyncdeffetch_url(session, url):asyncwith session.get(url) as response:returnawait response.text()asyncdefmain():    urls = ['http://example.com','http://example.org','http://example.net'    ]asyncwith aiohttp.ClientSession() as session:        tasks = [fetch_url(session, url) for url in urls]        results = await asyncio.gather(*tasks)return results# 计时比较start = time.time()results = asyncio.run(main())print(f"异步执行耗时: {time.time() - start:.2f}秒")

• 1
• 2
• 3

asyncwith aiohttp.ClientSession() as session:asyncwith session.get(url) as response:        data = await response.text()

• 1
• 2

asyncfor item in async_iterable:print(item)

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8
• 9

asyncdeffetch_with_limit(semaphore, url):asyncwith semaphore:asyncwith aiohttp.ClientSession() as session:asyncwith session.get(url) as response:returnawait response.text()# 限制最大并发数为5semaphore = asyncio.Semaphore(5)tasks = [fetch_with_limit(semaphore, url) for url in urls]

• 1
• 2
• 3
• 4
• 5
• 6
• 7
• 8

asyncdefsafe_fetch(url):try:asyncwith aiohttp.ClientSession() as session:asyncwith session.get(url) as response:returnawait response.text()except aiohttp.ClientError as e:print(f"请求失败: {e}")returnNone