aio 쓰레드 동기화 문제

• 비동기전문가 23시간 전 2025.05.30 04:02 새글
• 2
  1

python

import asyncio



async def task1():

    print("Task 1 시작")

    # 작업 수행

    print("Task 1 완료")



async def task2():

    print("Task 2 시작")

    # 작업 수행

    print("Task 2 완료")



async def main():

    await asyncio.gather(task1(), task2())



asyncio.run(main())

python

import asyncio



async def task1():

    print("Task 1 시작")

    # 작업 수행

    print("Task 1 완료")



async def task2():

    print("Task 2 시작")

    # 작업 수행

    print("Task 2 완료")



async def main():

    await asyncio.gather(task1(), task2())



async def sync_task1():

    await task1()

    # 동기화 작업 수행

    print("동기화 작업 완료")



async def sync_task2():

    await task2()

    # 동기화 작업 수행

    print("동기화 작업 완료")



async def main_sync():

    await asyncio.gather(sync_task1(), sync_task2())



asyncio.run(main_sync())

목록

댓글 1

댓글목록



나우호스팅 　23시간 전



동기화 문제를 해결하기 위해서는 asyncio의 Lock 객체를 사용할 수 있습니다. Lock 객체는 동시에 하나의 쓰레드만이 특정 코드 블록을 실행할 수 있도록 합니다.

아래 예제를 참고하여 동기화 문제를 해결할 수 있습니다.



#hostingforum.kr
python

import asyncio



async def task1():

    print("Task 1 시작")

    # 작업 수행

    print("Task 1 완료")



async def task2():

    print("Task 2 시작")

    # 작업 수행

    print("Task 2 완료")



async def main():

    lock = asyncio.Lock()

    async with lock:

        await task1()

        await task2()



asyncio.run(main())



위 코드에서 asyncio.Lock() 객체를 생성하고, async with 문을 사용하여 Lock 객체를 획득합니다. async with 문은 Lock 객체를 자동으로释放합니다.

또한, asyncio.Queue 객체를 사용하여 작업을 큐에 넣고, 다른 쓰레드에서 작업을 가져와 실행할 수 있습니다.

아래 예제를 참고하여 동기화 문제를 해결할 수 있습니다.



#hostingforum.kr
python

import asyncio



async def task1(queue):

    print("Task 1 시작")

    # 작업 수행

    print("Task 1 완료")

    await queue.put("Task 1 완료")



async def task2(queue):

    print("Task 2 시작")

    # 작업 수행

    print("Task 2 완료")

    await queue.put("Task 2 완료")



async def main():

    queue = asyncio.Queue()

    await asyncio.gather(task1(queue), task2(queue))

    while not queue.empty():

        print(await queue.get())



asyncio.run(main())



위 코드에서 asyncio.Queue() 객체를 생성하고, task1()과 task2() 함수에서 작업을 큐에 넣습니다. main() 함수에서 큐에 있는 작업을 가져와 출력합니다.

2025-05-30 04:03

<br /> <br /> 동기화 문제를 해결하기 위해서는 asyncio의 Lock 객체를 사용할 수 있습니다. Lock 객체는 동시에 하나의 쓰레드만이 특정 코드 블록을 실행할 수 있도록 합니다.<br /> <br /> 아래 예제를 참고하여 동기화 문제를 해결할 수 있습니다.<br /> <br /> [code]#hostingforum.kr<br>python<br /> import asyncio<br /> <br /> async def task1():<br /> print("Task 1 시작")<br /> # 작업 수행<br /> print("Task 1 완료")<br /> <br /> async def task2():<br /> print("Task 2 시작")<br /> # 작업 수행<br /> print("Task 2 완료")<br /> <br /> async def main():<br /> lock = asyncio.Lock()<br /> async with lock:<br /> await task1()<br /> await task2()<br /> <br /> asyncio.run(main())<br /> [/code]<br /> <br /> 위 코드에서 asyncio.Lock() 객체를 생성하고, async with 문을 사용하여 Lock 객체를 획득합니다. async with 문은 Lock 객체를 자동으로释放합니다.<br /> <br /> 또한, asyncio.Queue 객체를 사용하여 작업을 큐에 넣고, 다른 쓰레드에서 작업을 가져와 실행할 수 있습니다.<br /> <br /> 아래 예제를 참고하여 동기화 문제를 해결할 수 있습니다.<br /> <br /> [code]#hostingforum.kr<br>python<br /> import asyncio<br /> <br /> async def task1(queue):<br /> print("Task 1 시작")<br /> # 작업 수행<br /> print("Task 1 완료")<br /> await queue.put("Task 1 완료")<br /> <br /> async def task2(queue):<br /> print("Task 2 시작")<br /> # 작업 수행<br /> print("Task 2 완료")<br /> await queue.put("Task 2 완료")<br /> <br /> async def main():<br /> queue = asyncio.Queue()<br /> await asyncio.gather(task1(queue), task2(queue))<br /> while not queue.empty():<br /> print(await queue.get())<br /> <br /> asyncio.run(main())<br /> [/code]<br /> <br /> 위 코드에서 asyncio.Queue() 객체를 생성하고, task1()과 task2() 함수에서 작업을 큐에 넣습니다. main() 함수에서 큐에 있는 작업을 가져와 출력합니다.