Async/Await Python の「Fire and Forget」

問題ステートメント

Async/await は、Python での非同期プログラミングに便利な構文を提供します。ただし、完了を待たずに非同期操作を開始したい場合があります。これは、「ファイア アンド フォーゲット」と呼ばれることがよくあります。

asyncio.Task を使用した解決策

Python には、バックグラウンドで実行するタスクを作成できる asyncio.Task が用意されています。 asyncio.Task を使用すると、次のコードをスクリプトに追加することで、「ファイア アンド フォーゲット」を実現できます:

import asyncio

async def async_foo():
    # Do some asynchronous stuff here

# Create a task for async_foo()
asyncio.ensure_future(async_foo())

これにより、メイン スレッドをブロックせずに非同期で実行される async_foo() のタスクが作成されます。

保留中のタスクの処理

スクリプトの場合すべてのタスクが完了する前に完了する場合は、次のコードを使用して保留中のすべてのタスクを待つことができます。タスク:

pending_tasks = asyncio.Task.all_tasks()
loop.run_until_complete(asyncio.gather(*pending_tasks))

これにより、スクリプトが終了する前にすべてのタスクが確実に完了し、警告やエラーが発生しなくなります。

タスクのキャンセル

場合によっては、タスクが完了するまで待ちたくない場合もあります。次のコードを使用してそれらをキャンセルできます:

for task in pending_tasks:
    task.cancel()
    with suppress(asyncio.CancelledError):
        loop.run_until_complete(task)

これによりタスクがキャンセルされ、キャンセルの結果として発生する可能性のあるエラーが抑制されます。