asyncio.Task と asyncio.Future は非同期処理の基盤となるオブジェクトです。似ていますが、役割が異なります。
Future：将来の結果を表す
Future は「まだ完了していない計算の結果」を表すプレースホルダーです。
import asyncio async def main(): loop = asyncio.get_event_loop() future = loop.create_future() print(future.done()) # False future.set_result(42) print(future.done()) # True print(future.result()) # 42 asyncio.run(main())
Future は低レベル API で、通常は直接使いません。
Task：コルーチンをラップした Future
Task は Future のサブクラスで、コルーチンを実行してその結果を Future として提供します。
import asyncio async def fetch_data(): await asyncio.sleep(1) return "data" async def main(): task = asyncio.create_task(fetch_data()) print(type(task)) # <class '_asyncio.Task'> print(task.done()) # False result = await task print(result) # data print(task.done()) # True asyncio.run(main())
主な違い
Future
結果のプレースホルダー。外部から set_result() で結果を設定する。低レベル API。
Task
コルーチンを実行する。コルーチンの完了時に自動で結果が設定される。高レベル API。
Task のキャンセル
import asyncio async def long_running(): try: await asyncio.sleep(10) except asyncio.CancelledError: print("Task was cancelled") raise async def main(): task = asyncio.create_task(long_running()) await asyncio.sleep(0.1) task.cancel() try: await task except asyncio.CancelledError: print("Caught cancellation") asyncio.run(main())
複数の Task を管理
async def main(): tasks = [ asyncio.create_task(fetch_data()), asyncio.create_task(fetch_data()), ] results = await asyncio.gather(*tasks)
日常的な非同期プログラミングでは Task を使い、Future はライブラリ開発など低レベルな場面で使います。
