高レベルAPIインデックス
このページには、すべての高レベルのasync / await対応のasyncioAPIが一覧表示されます。
タスク
asyncioプログラムを実行し、タスクを作成し、タイムアウトで複数のものを待機するユーティリティ。
run()
|
イベントループを作成し、コルーチンを実行し、ループを閉じます。 |
create_task()
|
asyncioタスクを開始します。 |
await sleep()
|
数秒間スリープします。 |
await gather()
|
スケジュールと待機を同時に行います。 |
await wait_for()
|
タイムアウトで実行します。 |
await shield()
|
キャンセルから保護します。 |
await wait()
|
完了を監視します。 |
current_task()
|
現在のタスクを返します。 |
all_tasks()
|
イベントループのすべてのタスクを返します。 |
Task
|
タスクオブジェクト。 |
to_thread()
|
別のOSスレッドで関数を非同期的に実行します。 |
run_coroutine_threadsafe()
|
別のOSスレッドからコルーチンをスケジュールします。 |
for in as_completed()
|
for ループで完了を監視します。
|
例
- asyncio.gather()を使用して物事を並行して実行します。
- asyncio.wait_for()を使用してタイムアウトを強制します。
- キャンセル。
- asyncio.sleep()を使用します。
- メインのタスクのドキュメントページも参照してください。
キュー
キューは、複数の非同期タスク間で作業を分散し、接続プールを実装し、pub / subパターンを実装するために使用する必要があります。
Queue
|
FIFOキュー。 |
PriorityQueue
|
優先キュー。 |
LifoQueue
|
LIFOキュー。 |
例
サブプロセス
サブプロセスを生成し、シェルコマンドを実行するユーティリティ。
await create_subprocess_exec()
|
サブプロセスを作成します。 |
await create_subprocess_shell()
|
シェルコマンドを実行します。 |
例
- シェルコマンドの実行。
- サブプロセスAPI のドキュメントも参照してください。
ストリーム
ネットワークIOと連携する高レベルAPI。
await open_connection()
|
TCP接続を確立します。 |
await open_unix_connection()
|
Unixソケット接続を確立します。 |
await start_server()
|
TCPサーバーを起動します。 |
await start_unix_server()
|
Unixソケットサーバーを起動します。 |
StreamReader
|
ネットワークデータを受信するための高レベルの非同期/待機オブジェクト。 |
StreamWriter
|
ネットワークデータを送信するための高レベルの非同期/待機オブジェクト。 |
例
- TCPクライアントの例。
- ストリームAPI のドキュメントも参照してください。
同期
タスクで使用できるスレッドのような同期プリミティブ。
Lock
|
ミューテックスロック。 |
Event
|
イベントオブジェクト。 |
Condition
|
条件オブジェクト。 |
Semaphore
|
セマフォ。 |
BoundedSemaphore
|
境界のあるセマフォ。 |
例
- asyncio.Event を使用します。
- asyncio 同期プリミティブのドキュメントも参照してください。
例外
asyncio.TimeoutError
|
wait_for() などの関数によってタイムアウト時に発生します。 asyncio.TimeoutError は、組み込みの TimeoutError 例外と無関係であることに注意してください。
|
asyncio.CancelledError
|
タスクがキャンセルされたときに発生します。 Task.cancel()も参照してください。 |
例
- キャンセルリクエストでコードを実行するためのCancelledErrorの処理。
- 非同期固有の例外の完全なリストも参照してください。