Microsoft MVP성태의 닷넷 이야기
스크립트: 58. 파이썬 - async/await 기본 사용법 [링크 복사], [링크+제목 복사],
조회: 10975
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

(시리즈 글이 3개 있습니다.)
스크립트: 58. 파이썬 - async/await 기본 사용법
; https://www.sysnet.pe.kr/2/0/13423

스크립트: 59. 파이썬 - 비동기 호출 함수(run_until_complete, run_in_executor, create_task, run_in_threadpool)
; https://www.sysnet.pe.kr/2/0/13426

스크립트: 71. 파이썬 - asyncio의 ContextVar 전달
; https://www.sysnet.pe.kr/2/0/13899




파이썬 - async/await 기본 사용법

C# 개발자라면, 파이썬의 async/await를 유사한 경험으로 사용할 수 있습니다. 우선, 간단하게 콘솔 앱으로 예제를 작성해 볼까요? ^^

async def main_async():
    print('async called')

await main_async()

""" 
실행 결과:

  File "C:\test\main.py", line 6
    await main_async()
    ^
SyntaxError: 'await' outside function
"""

위의 코드를 실행하면 "실행 결과"에서 보는 바대로 await을 함수 밖에서 사용했다고 오류가 발생합니다. 그래서 이것을 함수에 담아서 다시 호출해 보면,

import time

async def do_something(delay: int=0):
    time.sleep(delay)
    return delay

def main():
    await do_something(3)

main()


""" 
실행 결과:

  File "/home/testusr/main.py", line 10
    await do_something(3)
    ^
SyntaxError: 'await' outside async function
"""

이번엔 async 함수가 아닌 곳에서 사용했다고 나옵니다. 그렇다면 main 함수를 async로 만들어야 하지만,

async def main():
    await do_something(3)

main()

""" 
실행 결과:

/home/testusr/main.py:12: RuntimeWarning: coroutine 'main' was never awaited
  main()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
"""

그럼 main 함수가 비동기 호출 처리가 안 되었다는 불평을 하게 되므로, 결국 main 호출도 "await main()"으로 바꿔야 하고 문제가 다시 원점으로 돌아가게 됩니다.




C#은 Main 메서드 시작부터 async Main으로 만드는 것이 가능하지만 파이썬은 그에 대한 처리는 없기 때문에 이런 경우 라이브러리의 도움을 받아야 합니다. 실제로 최초의 async 진입 함수를 asyncio.run 등의 함수를 이용해 실행하면,

import time
import asyncio

async def main_async():
    print('async calling', time.strftime('%X'))
    time.sleep(5)
    print('async called', time.strftime('%X'))

asyncio.run(main_async())

""" 
실행 결과:

async calling 14:06:08
async called 14:06:13
""" 

아무런 문제 없이 코드가 수행됩니다. 또한 await을 순차적으로 비동기 처리하는 것은 C#의 체계와 같습니다. 그래서 아래의 코드는 총 9초를 소요하게 되는데요,

import time
import asyncio

async def do_something(delay: int=0):
    time.sleep(delay)


async def main_async():
    print('async calling', time.strftime('%X'))
    await do_something(3)
    await do_something(6)
    print('async called', time.strftime('%X'))  # 9초 지나서 실행
                                                # 아래에서 다루겠지만, do_something 함수 내부의 코드 문제로 비동기 처리와 무관하게 9초가 걸립니다.
    

asyncio.run(main_async())

그렇다면 병렬처리는 어떻게 할 수 있을까요? C#의 경우라면 개별 호출을 Task로 받아 await을 별도로 진행하거나 Task.WhenAll로 받을 수 있는데요, 파이썬도 유사한 사용자 경험을 제공합니다.

실제로 해볼까요? ^^ 우선, C#처럼 다음과 같이 코딩하면,

task1 = do_something(3)  # 동기 호출: 이곳에서 time.sleep(3) 코드 동작
task2 = do_something(6)  # 동기 호출: 이곳에서 time.sleep(6) 코드 동작

await task1
await task2

위의 호출은 총 9초가 소요됩니다. 사실 "task1 = do_something(...)" 형식이 동기 호출이든 비동기 호출이든 상관없이 저 코드는 총 9초가 소요됩니다. 왜냐하면 do_something의 내부에 있는 time.sleep이 동기적으로 호출되기 때문에 그것을 호출하는 측의 스레드가 그대로 묶이기 때문입니다.

따라서, 이 문제를 없애려면 time.sleep도 비동기 버전을 사용해야 합니다.

async def do_something(delay: int=0):
    await asyncio.sleep(delay)


task1 = do_something(3)  # 동기 호출이지만 asyncio.sleep 비동기 호출로 3초를 대기하지 않고 제어 반환
task2 = do_something(6)  # 동기 호출이지만 asyncio.sleep 비동기 호출로 6초를 대기하지 않고 제어 반환

await task1  # 이곳에서 비동기 3초 작업 대기
await task2  # 이미 3초가 흘렀으므로 남은 비동기 3초 대기

# 총 6초 소요

보는 바와 같이, 이제야 원하는 대로 병렬 처리가 잘 되었습니다. (저렇게 보면 C#의 코드와 거의 같습니다.)

또한, 파이썬 역시 C#의 Task.WhenAll과 유사하게 병렬 처리를 위한 전용 함수인 asyncio.gather를 제공합니다. 따라서 이것을 이용하면 다음과 같이 재작성할 수 있습니다.

# Can I use await on multiple functions at once?
# https://stackoverflow.com/questions/68733675/can-i-use-await-on-multiple-functions-at-once

import time
import asyncio

async def do_something(delay: int=0):
    await asyncio.sleep(delay)


async def main_async():
    print('async calling', time.strftime('%X'))

    await asyncio.gather(do_something(3), do_something(6))  # 6초 소요

    print('async called', time.strftime('%X'))


asyncio.run(main_async())

참고로, gather의 경우 인자를 개별적으로 지정하는데, 인자가 포함된 리스트를 받는 wait 함수를 쓰는 것도 가능합니다. (gather/wait)

async def main_async():
    print('async calling', time.strftime('%X'))

    jobs = [do_something(3), do_something(6)]  # 리스트로 전달
    await asyncio.wait(jobs)  # 6초 소요

    print('async called', time.strftime('%X'))




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 10/13/2023]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  4  5  6  7  8  [9]  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13718정성태8/27/20247409오류 유형: 921. Visual C++ - error C1083: Cannot open include file: 'float.h': No such file or directory [2]
13717정성태8/26/20247015VS.NET IDE: 192. Visual Studio 2022 - Windows XP / 2003용 C/C++ 프로젝트 빌드
13716정성태8/21/20246748C/C++: 167. Visual C++ - 윈도우 환경에서 _execv 동작 [1]
13715정성태8/19/20247346Linux: 78. 리눅스 C/C++ - 특정 버전의 glibc 빌드 (docker-glibc-builder)
13714정성태8/19/20246735닷넷: 2295. C# 12 - 기본 생성자(Primary constructors) (책 오타 수정) [3]
13713정성태8/16/20247443개발 환경 구성: 721. WSL 2에서의 Hyper-V Socket 연동
13712정성태8/14/20247214개발 환경 구성: 720. Synology NAS - docker 원격 제어를 위한 TCP 바인딩 추가
13711정성태8/13/20248054Linux: 77. C# / Linux - zombie process (defunct process) [1]파일 다운로드1
13710정성태8/8/20247971닷넷: 2294. C# 13 - (6) iterator 또는 비동기 메서드에서 ref와 unsafe 사용을 부분적으로 허용파일 다운로드1
13709정성태8/7/20247736닷넷: 2293. C# - safe/unsafe 문맥에 대한 C# 13의 (하위 호환을 깨는) 변화파일 다운로드1
13708정성태8/7/20247526개발 환경 구성: 719. ffmpeg / YoutubeExplode - mp4 동영상 파일로부터 Audio 파일 추출
13707정성태8/6/20247755닷넷: 2292. C# - 자식 프로세스의 출력이 4,096보다 많은 경우 Process.WaitForExit 호출 시 hang 현상파일 다운로드1
13706정성태8/5/20247881개발 환경 구성: 718. Hyper-V - 리눅스 VM에 새로운 디스크 추가
13705정성태8/4/20248144닷넷: 2291. C# 13 - (5) params 인자 타입으로 컬렉션 허용 [2]파일 다운로드1
13704정성태8/2/20248099닷넷: 2290. C# - 간이 dotnet-dump 프로그램 만들기파일 다운로드1
13703정성태8/1/20247426닷넷: 2289. "dotnet-dump ps" 명령어가 닷넷 프로세스를 찾는 방법
13702정성태7/31/20247825닷넷: 2288. Collection 식을 지원하는 사용자 정의 타입을 CollectionBuilder 특성으로 성능 보완파일 다운로드1
13701정성태7/30/20248097닷넷: 2287. C# 13 - (4) Indexer를 이용한 개체 초기화 구문에서 System.Index 연산자 허용파일 다운로드1
13700정성태7/29/20247696디버깅 기술: 200. DLL Export/Import의 Hint 의미
13699정성태7/27/20248223닷넷: 2286. C# 13 - (3) Monitor를 대체할 Lock 타입파일 다운로드1
13698정성태7/27/20248186닷넷: 2285. C# - async 메서드에서의 System.Threading.Lock 잠금 처리파일 다운로드1
13697정성태7/26/20247911닷넷: 2284. C# - async 메서드에서의 lock/Monitor.Enter/Exit 잠금 처리파일 다운로드1
13696정성태7/26/20247439오류 유형: 920. dotnet publish - error NETSDK1047: Assets file '...\obj\project.assets.json' doesn't have a target for '...'
13695정성태7/25/20247423닷넷: 2283. C# - Lock / Wait 상태에서도 STA COM 메서드 호출 처리파일 다운로드1
13694정성태7/25/20247887닷넷: 2282. C# - ASP.NET Core Web App의 Request 용량 상한값 (Kestrel, IIS)
13693정성태7/24/20247222개발 환경 구성: 717. Visual Studio - C# 프로젝트에서 레지스트리에 등록하지 않은 COM 개체 참조 및 사용 방법파일 다운로드1
1  2  3  4  5  6  7  8  [9]  10  11  12  13  14  15  ...