PricingLoginStart free
Python Academy · Pelajaran

await, Tugasan dan Pengumpulan

Gunakan await, asyncio.create_task dan asyncio.gather untuk keserentakan.

Pelajaran 2 daripada 413 langkah

await, Tugasan dan Pengumpulan ialah pelajaran Python Academy percuma di CoddyKit. Ini ialah pelajaran 2 daripada 4. Anda boleh membaca keseluruhan pelajaran di bawah secara percuma — kemudian berlatih secara praktikal dalam pelayar menggunakan penyunting kod terbina dalam dan tutor kecerdasan buatan 24/7. Pelajaran ini merupakan sebahagian daripada laluan pembelajaran Python Academy, dan kemajuan anda disegerakkan merentas web serta aplikasi CoddyKit. Kursus Python Academy merangkumi sejumlah 4 pelajaran.

await berbanding Berjujukan

Menggunakan await sahaja menjalankan korutin secara berjujukan. Untuk menjalankannya serentak, bungkus korutin tersebut dalam tugas.

import asyncio

async def main():
    # Sequential — total ~3 s
    await asyncio.sleep(2)
    await asyncio.sleep(1)

    # Concurrent using gather — total ~2 s
    await asyncio.gather(asyncio.sleep(2), asyncio.sleep(1))

asyncio.create_task()

asyncio.create_task(coro) menjadualkan korutin untuk dijalankan sebagai tugas bebas secara serentak dengan korutin semasa.

import asyncio

async def work(n):
    await asyncio.sleep(n)
    return n

async def main():
    t1 = asyncio.create_task(work(2))
    t2 = asyncio.create_task(work(1))
    r1 = await t1
    r2 = await t2
    print(r1, r2)   # 2 1 (total ~2 s)

asyncio.run(main())

asyncio.gather()

asyncio.gather(*coros) menjalankan korutin secara serentak dan mengembalikan semua hasil mengikut urutan apabila kesemuanya selesai.

import asyncio

async def fetch(i):
    await asyncio.sleep(1)
    return f"data-{i}"

async def main():
    results = await asyncio.gather(fetch(1), fetch(2), fetch(3))
    print(results)  # ["data-1", "data-2", "data-3"] in ~1 s

asyncio.run(main())

gather dengan return_exceptions

Tetapkan return_exceptions=True supaya korutin yang gagal mengembalikan pengecualiannya sebagai hasil dan bukannya membatalkan keseluruhan gather.

import asyncio

async def risky(n):
    if n == 2: raise ValueError("bad")
    return n

async def main():
    results = await asyncio.gather(
        risky(1), risky(2), risky(3),
        return_exceptions=True
    )
    print(results)   # [1, ValueError("bad"), 3]

asyncio.wait()

asyncio.wait(tasks, return_when=...) mengembalikan dua set: done dan pending. Gunakan FIRST_COMPLETED untuk bertindak balas terhadap hasil pertama.

import asyncio

async def slow(): await asyncio.sleep(3); return "slow"
async def fast(): await asyncio.sleep(1); return "fast"

async def main():
    tasks = {asyncio.create_task(slow()), asyncio.create_task(fast())}
    done, pending = await asyncio.wait(tasks, return_when=asyncio.FIRST_COMPLETED)
    for t in pending: t.cancel()

Pembatalan tugas

Panggil task.cancel() untuk meminta pembatalan. Tugas tersebut menerima asyncio.CancelledError pada titik await yang seterusnya.

import asyncio

async def long_job():
    try:
        await asyncio.sleep(100)
    except asyncio.CancelledError:
        print("Cancelled!")
        raise   # re-raise is required

async def main():
    t = asyncio.create_task(long_job())
    await asyncio.sleep(1)
    t.cancel()
    await t

asyncio.timeout() — Python 3.11+

Balut operasi await dengan asyncio.timeout(seconds) untuk membatalkan operasi jika mengambil masa terlalu lama.

import asyncio

async def main():
    try:
        async with asyncio.timeout(2):
            await asyncio.sleep(10)   # too slow
    except TimeoutError:
        print("Timed out!")

asyncio.wait_for()

Pada Python < 3.11, gunakan asyncio.wait_for(coro, timeout=N) untuk menambah had masa, yang akan mencetuskan asyncio.TimeoutError.

import asyncio

async def slow(): await asyncio.sleep(5)

async def main():
    try:
        await asyncio.wait_for(slow(), timeout=2)
    except asyncio.TimeoutError:
        print("Timed out")

Nama dan pemeriksaan tugas

Namakan tugas untuk memudahkan penyahpepijatan dengan asyncio.create_task(coro, name="...") dan periksa namanya dengan task.get_name().

import asyncio

async def worker(): await asyncio.sleep(1)

async def main():
    t = asyncio.create_task(worker(), name="worker-1")
    print(t.get_name())   # worker-1
    await t

TaskGroup — Python 3.11+

asyncio.TaskGroup mencipta kumpulan tugas berstruktur. Jika mana-mana tugas mencetuskan ralat, semua tugas akan dibatalkan.

import asyncio

async def main():
    async with asyncio.TaskGroup() as tg:
        t1 = tg.create_task(asyncio.sleep(1))
        t2 = tg.create_task(asyncio.sleep(2))
    # all tasks done here

Semaphore untuk pengehad kadar

Gunakan asyncio.Semaphore(n) untuk mengehadkan bilangan operasi serentak, contohnya panggilan API.

import asyncio

sem = asyncio.Semaphore(5)  # max 5 concurrent

async def limited_fetch(url):
    async with sem:
        await fetch(url)   # at most 5 at a time

Semakan pantas

Apakah perbezaan antara await coro() dengan asyncio.create_task(coro())?

Jawab dalam pelajaran interaktif

Imbas kembali

Gunakan create_task atau gather untuk pelaksanaan serentak. gather mengumpulkan semua hasil; wait memberikan kawalan terperinci. Batalkan tugas dengan .cancel() dan gunakan had masa dengan wait_for atau asyncio.timeout.

Percuma untuk bermula

Pelajari Python dengan tutor kecerdasan buatan — percuma

Tulis dan jalankan kod sebenar dalam pelayar anda, dapatkan bantuan segera daripada tutor kecerdasan buatan yang tersedia 24/7, dan sambung semula dari tempat anda berhenti di web atau dalam aplikasi.

Kursus
76
Pelajaran
320
Mula belajar secara percumaLihat kursus penuh

Soalan Lazim

Adakah pelajaran “await, Tugasan dan Pengumpulan” percuma?

Ya — teks penuh “await, Tugasan dan Pengumpulan” boleh dibaca secara percuma di web ini. Untuk berlatih secara interaktif menggunakan penyunting kod terbina dalam dan tutor kecerdasan buatan 24/7, serta membuka kunci baki kursus Python Academy, tingkat taraf kepada CoddyKit PRO. Kursus Python Academy merangkumi sejumlah 4 pelajaran.

Apakah yang akan saya pelajari dalam “await, Tugasan dan Pengumpulan”?

Gunakan await, asyncio.create_task dan asyncio.gather untuk keserentakan. Anda berlatih Python Academy menggunakan kod praktikal yang dijalankan terus dalam pelayar, manakala tutor kecerdasan buatan 24/7 menjawab soalan anda semasa anda mengikuti pelajaran.

Adakah saya memerlukan pengalaman untuk memulakan Python Academy?

Tiada pengalaman terdahulu diperlukan. Pembelajaran Python Academy di CoddyKit disusun untuk pelajar daripada peringkat pemula hingga lanjutan, jadi anda boleh bermula di sini atau dari awal dan belajar mengikut kadar anda sendiri. Ini ialah pelajaran 2 daripada 4.

Berapa lamakah pelajaran “await, Tugasan dan Pengumpulan” diambil?

Kebanyakan pelajaran CoddyKit mengambil masa kira-kira 5–10 minit. Setiap pelajaran ringkas dan interaktif, jadi anda boleh membuat kemajuan secara berterusan dan menyambung tepat dari tempat anda berhenti di web atau aplikasi.

Bolehkah saya menulis dan menjalankan kod dalam pelajaran Python Academy ini?

Ya. Setiap pelajaran Python Academy menyertakan penyunting kod terbina dalam, jadi anda boleh menulis dan menjalankan kod sebenar terus dalam pelayar serta menerima maklum balas kecerdasan buatan serta-merta — tanpa memerlukan persediaan setempat.

Semua pelajaran dalam kursus ini

  1. Korutin dan Gelung Peristiwa
  2. await, Tugasan dan Pengumpulan
  3. Pengurus Konteks dan Lelaran Tak Segerak
  4. Corak I/O Tak Segerak dalam Pengeluaran
← Kembali ke Python Academy