Temui kuasa asyncio: mendayakan operasi tak segerak yang lancar

Intipati pengaturcaraan tak segerak

Penyegerakan tradisional Pengaturcaraanmodel menyekat aliran pelaksanaan aplikasi sehingga operasi selesai. Ini tidak cekap semasa mengendalikan tugas intensif I/O kerana aplikasi mesti menunggu operasi ini selesai, mengakibatkan kependaman dan sumber terbuang.

Pengaturcaraan tak segerak mengatasi had ini dengan menggunakan coroutine. Coroutine ialah fungsi ringan yang boleh dijeda dan disambung semula pada bila-bila masa. Apabila coroutine menghadapi operasi menyekat (seperti permintaan rangkaian), ia boleh menjeda pelaksanaan dan membiarkan aplikasi mengendalikan tugas lain. Apabila operasi menyekat selesai, coroutine boleh menyambung semula pelaksanaan dan meneruskan di tempat ia berhenti.

perpustakaan asyncio

asyncio ialah perpustakaan pengaturcaraan tak segerak untuk python yang menyediakan set komprehensif alat untuk menulis aplikasi concurrency berprestasi tinggi. Ia berdasarkan coroutine dan gelung peristiwa, membolehkan pembangun melakukan operasi tak segerak tanpa menyekat benang utama.

Coroutine

Dalam asyncio, coroutine ialah fungsi yang diisytiharkan menggunakan kata kunci async def 关键字声明的函数。它们具有 aw<strong class="keylink">ai</strong>t. Mereka mempunyai ungkapan aw

t yang menjeda pelaksanaan dan menunggu operasi tak segerak dalam coroutine selesai. Contohnya: fetch_data 是一个协程，它使用 aiohttp

async def fetch_data(url):
async with aioHttp.ClientSession() as session:
async with session.get(url) as response:
return await response.JSON()

mengambil data secara tidak segerak pada URL yang diberikan.

asyncio bergantung pada gelung acara untuk mengurus pelaksanaan coroutine. Gelung peristiwa ialah gelung tak terhingga yang bermula dengan coroutine dan terus melaksanakan coroutine sehingga mereka selesai atau dijeda. Ia bertanggungjawab untuk menjadualkan coroutine dan mengendalikan acara daripada

atau sumber lain.

Menulis aplikasi tak segerak menggunakan asyncio memerlukan langkah berikut:
1. asyncio.new_event_loop()Buat gelung acara:
Gunakan
2. untuk membuat gelung acara. async defBuat coroutine:
Gunakan kata kunci
3. untuk mengisytiharkan coroutine. asyncio.create_task() 或 asyncio.ensure_future()Menjadualkan coroutine:
Gunakan
4. untuk menjadualkan coroutine ke dalam gelung acara. asyncio.run()Mulakan gelung acara:
Gunakan

import asyncio

async def main():
# 异步获取数据
data = await fetch_data("https://example.com/data.json")

# 处理数据
print(data)

# 创建事件循环并启动它
asyncio.run(main())