Bagaimana untuk Mencapai Kelakuan 'Fire and Forget' dalam Async/Await Python 3.5?

"Fire and Forget" Python Async/Await

Dalam pengaturcaraan asynchronous, ia boleh berguna untuk melaksanakan operasi tidak kritikal tanpa menunggu penyempurnaan mereka. Dalam Tornado, gelagat "api dan lupa" ini boleh dicapai dengan meninggalkan kata kunci hasil dalam coroutine. Walau bagaimanapun, dalam sintaks async/menunggu Python 3.5, pendekatan ini menghasilkan amaran masa jalan dan tidak melaksanakan operasi yang diingini.

Penyelesaian: asyncio.Task

Menurut dokumentasi Python untuk asyncio.Task, ia membenarkan pelaksanaan coroutine "dalam latar belakang." Dengan menggunakan asyncio.ensure_future untuk menghasilkan tugasan, pelaksanaan tidak disekat dan fungsi itu kembali serta-merta, serupa dengan gelagat "fire and forget".

import asyncio

async def async_foo():
    print("async_foo started")
    await asyncio.sleep(1)
    print("async_foo done")

async def main():
    asyncio.ensure_future(async_foo())  # fire and forget async_foo()

    # Perform other actions

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

Output:

async_foo started
Do some actions 1
async_foo done
Do some actions 2
Do some actions 3

Mengendalikan Tugas Tertunda

Jika tugasan masih dilaksanakan selepas gelung acara telah selesai, amaran mungkin dipaparkan. Untuk mengelakkan ini, semua tugasan yang belum selesai boleh ditunggu sebaik sahaja gelung acara selesai:

# Let's also finish all running tasks:
pending = asyncio.Task.all_tasks()
loop.run_until_complete(asyncio.gather(*pending))

Membatalkan Tugas

Dalam sesetengah kes, tugasan mungkin perlu dibatalkan yang tidak dijangka akan selesai. Ini boleh dicapai menggunakan task.cancel():

# Let's also cancel all running tasks:
pending = asyncio.Task.all_tasks()
for task in pending:
    task.cancel()
    # Now we should await task to execute it's cancellation.
    # Cancelled task raises asyncio.CancelledError that we can suppress:
    with suppress(asyncio.CancelledError):
        loop.run_until_complete(task)

Atas ialah kandungan terperinci Bagaimana untuk Mencapai Kelakuan 'Fire and Forget' dalam Async/Await Python 3.5?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!