高水準の API インデックス

このページには、すべての高水準の 非同期/待機 可能な asyncio API が一覧になっています。

Task

ユーティリティは asyncio プログラムを実行し、タスクを作成し、タイムアウトのある複数の機能を待っています。

run()

イベントループを作成し、コルーチンを実行し、ループを閉じます。

Runner

複数の非同期関数呼び出しをシンプルにするコンテキストマネージャ。

Task

Task オブジェクト

TaskGroup

タスクのグループを保持するコンテキストマネージャ。グループに属するすべてのタスクが完了するのを待つのに便利で信頼性のある方法を提供します。

create_task()

Start an asyncio Task, then returns it.

current_task()

現在のタスクを返します。

all_tasks()

Return all tasks that are not yet finished for an event loop.

await sleep()

数秒間スリープします。

await gather()

並行してスケジュールして、待ちます。

await wait_for()

タイムアウトで実行します。

await shield()

取り消しから保護します。

await wait()

完了かどうかを監視します。

timeout()

Run with a timeout. Useful in cases when wait_for is not suitable.

to_thread()

Asynchronously run a function in a separate OS thread.

run_coroutine_threadsafe()

別の OS スレッドからコルーチンの実行をスケジュールします。

for in as_completed()

for ループ向けにコルーチンの完了を監視します。

使用例

キュー

キューは複数の非同期タスクの分散処理、コネクションプールやpub/subパターンの実装に適しています。

Queue

FIFO キューです。

PriorityQueue

優先度付きのキューです。

LifoQueue

LIFO キュー (スタック) です。

使用例

サブプロセス

サブプロセスを生成したり、シェルコマンドを実行するためのユーティリティです。

await create_subprocess_exec()

サブプロセスを作成します。

await create_subprocess_shell()

シェルコマンドを実行します。

使用例

ストリーム

ネットワーク IO を利用するための高水準の APIs です。

await open_connection()

TCP コネクションを確立します。

await open_unix_connection()

Unix のソケット接続を確立します。

await start_server()

TCP サーバーを起動します。

await start_unix_server()

Unix のソケットサーバーを起動します。

StreamReader

ネットワークからデータを受信するための高水準の async/await オブジェクトです。

StreamWriter

ネットワークにデータを送信するための高水準の async/await オブジェクトです。

使用例

同期

タスク内で利用できるスレッド並列処理に似た同期プリミティブです。

Lock

ミューテックスロックです。

Event

イベントオブジェクトです。

Condition

条件変数オブジェクトです。

Semaphore

セマフォ (semaphore) です。

BoundedSemaphore

有限セマフォ (bounded semaphore) です。

Barrier

A barrier object.

使用例

例外

asyncio.CancelledError

タスクがキャンセルされた場合に送出されます。 Task.cancel() も参照してください。

asyncio.BrokenBarrierError

Raised when a Barrier is broken. See also Barrier.wait().

使用例