Python

고수준 API 색인

이 페이지에는 모든 고수준의 async/await 활성화된 asyncio API가 나열됩니다.

태스크

asyncio 프로그램을 실행하고, 태스크를 만들고, 시간제한 있게 여러 가지를 기다리는 유틸리티.

run()

이벤트 루프를 만들고, 코루틴을 실행하고, 루프를 닫습니다.

Runner

여러 비동기 함수 호출을 간소화하는 컨텍스트 관리자입니다.

Task

Task 객체.

TaskGroup

작업 그룹을 보유하는 컨텍스트 관리자입니다. 그룹 내 모든 작업이 완료되기를 기다릴 편리하고 신뢰할 수 있는 방법을 제공합니다.

create_task()

asyncio Task를 시작한 후 반환합니다.

current_task()

현재 Task를 돌려줍니다.

all_tasks()

이벤트 루프의 아직 종료하지 않은 모든 태스크를 반환합니다.

await sleep()

몇 초 동안 잠잡니다.

await gather()

여러 가지를 동시에 예약하고 기다립니다.

await wait_for()

시간제한 있게 실행합니다.

await shield()

취소로부터 보호합니다.

await wait()

완료를 감시합니다.

timeout()

타임아웃을 지정하여 실행합니다. `wait_for`가 적합하지 않은 경우 유용합니다.

to_thread()

별도의 OS 스레드에서 함수를 비동기적으로 실행합니다.

run_coroutine_threadsafe()

다른 OS 스레드에서 코루틴을 예약합니다.

for in as_completed()

for 루프로 완료를 감시합니다.

예제

큐는 여러 asyncio 태스크 간에 작업을 분산하고, 연결 풀과 pub/sub 패턴을 구현하는 데 사용해야 합니다.

Queue

FIFO 큐.

PriorityQueue

우선순위 큐.

LifoQueue

LIFO 큐.

예제

서브 프로세스

서브 프로세스를 생성하고 셸 명령을 실행하는 유틸리티.

await create_subprocess_exec()

서브 프로세스를 만듭니다.

await create_subprocess_shell()

셸 명령을 실행합니다.

예제

스트림

네트워크 IO로 작업하는 고수준 API

await open_connection()

TCP 연결을 만듭니다.

await open_unix_connection()

유닉스 소켓 연결을 만듭니다.

await start_server()

TCP 서버를 시작합니다.

await start_unix_server()

유닉스 소켓 서버를 시작합니다.

StreamReader

네트워크 데이터를 수신하는 고수준 async/await 객체.

StreamWriter

네트워크 데이터를 보내는 고수준 async/await 객체.

예제

동기화

태스크에 쓸 수 있는 threading과 유사한 동기화 프리미티브.

Lock

뮤텍스 록.

Event

이벤트 객체.

Condition

조건 객체.

Semaphore

세마포어.

BoundedSemaphore

제한된 세마포어.

Barrier

장벽 객체.

예제

예외

asyncio.CancelledError

Task가 취소될 때 발생합니다. Task.cancel()도 참조하십시오.

asyncio.BrokenBarrierError

Barrier 가 깨질 때 발생합니다. Barrier.wait()도 참조하십시오.

예제

분실물 보관소