Chỉ số API cấp cao

Trang này liệt kê tất cả các API asyncio được kích hoạt async/await cấp cao.

Nhiệm vụ

Các tiện ích để chạy các chương trình asyncio, tạo Nhiệm vụ và chờ đợi nhiều thứ khi hết thời gian chờ.

run()	Tạo vòng lặp sự kiện, chạy coroutine, đóng vòng lặp.
Runner	Trình quản lý bối cảnh giúp đơn giản hóa nhiều lệnh gọi hàm không đồng bộ.
Task	Đối tượng nhiệm vụ.
TaskGroup	Trình quản lý bối cảnh chứa một nhóm nhiệm vụ. Cung cấp một cách thuận tiện và đáng tin cậy để chờ tất cả nhiệm vụ trong nhóm hoàn thành.
create_task()	Bắt đầu một tác vụ asyncio, sau đó trả về nó.
current_task()	Trả về nhiệm vụ hiện tại.
all_tasks()	Trả về tất cả các nhiệm vụ chưa hoàn thành cho vòng lặp sự kiện.
await sleep()	Ngủ trong vài giây.
await gather()	Lên lịch và chờ đợi mọi thứ cùng một lúc.
await wait_for()	Chạy với thời gian chờ.
await shield()	Bảo vệ khỏi việc hủy bỏ.
await wait()	Giám sát để hoàn thành.
timeout()	Chạy với thời gian chờ. Hữu ích trong trường hợp wait_for không phù hợp.
to_thread()	Chạy không đồng bộ một chức năng trong một luồng hệ điều hành riêng biệt.
run_coroutine_threadsafe()	Lên lịch coroutine từ một luồng hệ điều hành khác.
for in as_completed()	Giám sát quá trình hoàn thành bằng vòng lặp for.

Ví dụ

• Using asyncio.gather() to run things in parallel.

• Using asyncio.wait_for() to enforce a timeout.

• Cancellation.

• Using asyncio.sleep().

• Xem thêm Tasks documentation page chính.

Hàng đợi

Hàng đợi nên được sử dụng để phân phối công việc giữa nhiều Nhiệm vụ không đồng bộ, triển khai nhóm kết nối và mẫu pub/sub.

Queue	Một hàng đợi FIFO.
PriorityQueue	Một hàng đợi ưu tiên.
LifoQueue	Một hàng đợi LIFO.

Ví dụ

• Using asyncio.Queue to distribute workload between several Tasks.

• Xem thêm Queues documentation page.

Quy trình con

Các tiện ích để tạo ra các quy trình con và chạy các lệnh shell.

await create_subprocess_exec()	Tạo một quy trình con.
await create_subprocess_shell()	Chạy lệnh shell.

Ví dụ

• Executing a shell command.

• Xem thêm tài liệu subprocess APIs.

Luồng

API cấp cao để hoạt động với mạng IO.

await open_connection()	Thiết lập kết nối TCP.
await open_unix_connection()	Thiết lập kết nối ổ cắm Unix.
await start_server()	Khởi động máy chủ TCP.
await start_unix_server()	Khởi động một máy chủ socket Unix.
StreamReader	Đối tượng async/await cấp cao để nhận dữ liệu mạng.
StreamWriter	Đối tượng async/await cấp cao để gửi dữ liệu mạng.

Ví dụ

• Example TCP client.

• Xem thêm tài liệu streams APIs.

Đồng bộ hóa

Các nguyên tắc đồng bộ hóa giống như luồng có thể được sử dụng trong Nhiệm vụ.

Lock	Một khóa mutex.
Event	Một đối tượng sự kiện
Condition	Một đối tượng điều kiện.
Semaphore	Một đèn hiệu.
BoundedSemaphore	Một semaphore giới hạn.
Barrier	Một vật cản.

Ví dụ

• Using asyncio.Event.

• Using asyncio.Barrier.

• Xem thêm tài liệu của asyncio synchronization primitives.

Ngoại lệ

asyncio.CancelledError	Xảy ra khi một Tác vụ bị hủy. Xem thêm Task.cancel().
asyncio.BrokenBarrierError	Tăng lên khi Rào chắn bị phá vỡ. Xem thêm Barrier.wait().

Ví dụ

• Handling CancelledError to run code on cancellation request.

• Xem thêm danh sách đầy đủ của asyncio-specific exceptions.