파이썬 asyncio.Lock()은 무엇입니까?

Question

coroutines가 미래에 선점 될 수 있기 때문입니까? 아니면 사람들이 중요한 섹션에서 수익을 사용할 수 있습니다 (IMO는 권장하지 말아야 함)?

Answer 1

임계 값 섹션을 보호하기 위해 스레드 코드에서 잠금을 사용하는 것과 같은 이유로 이것을 사용합니다. asyncio은 기본적으로 단일 스레드 코드에서 사용하기위한 것이지만 동시 실행이 발생하기 때문에 때때로 동기화가 필요합니다.

@asyncio.coroutine 
def get_stuff(url): 
    if url in cache: 
     return cache[url] 
    stuff = yield from aiohttp.request('GET', url) 
    cache[url] = stuff 
    return stuff 

지금 당신은 동시에 그 잠재적해야 할 수도 있습니다 실행하는 여러 공동 루틴을 가지고 있다고 가정 :

예를 들어, 다음 웹 서버에서 일부 데이터를 가져 오는 및 기능을 고려하여 결과를 캐시합니다

def parse_stuff(): 
    stuff = yield from get_stuff() 
    # do some parsing 

def use_stuff(): 
    stuff = yield from get_stuff() 
    # use stuff to do something interesting 

def do_work(): 
    out = yield from aiohttp.request("www.awebsite.com") 
    # do some work with out 


tasks = [ 
    asyncio.async(parse_stuff()), 
    asyncio.async(use_stuff()), 
    asyncio.async(do_work()), 
] 
loop = asyncio.get_event_loop() 
loop.run_until_complete(asyncio.wait(tasks)) 

지금, url에서 데이터를 가져 오는 것은 느린 인 척 : get_stuff의 반환 값을 사용합니다. parse_stuff과 use_stuff이 동시에 실행되는 경우 각각은 stuff을 가져 오기 위해 네트워크를 통해 이동하는 데 드는 모든 비용이 부과됩니다. 당신이 잠금 방법을 보호하는 경우에는이를 방지 :

stuff_lock = asyncio.Lock() 

def get_stuff(url): 
    with (yield from stuff_lock): 
     if url in cache: 
      return cache[url] 
     stuff = yield from aiohttp.request('GET', url) 
     cache[url] = stuff 
     return stuff 

주목해야 할 또 다른 일이 하나 코 루틴 내부 get_stuff의 aiohttp 통화를하고, stuff_lock 다른 대기, 아무튼 제 코 루틴 동안 Lock에있는 코 루틴 차단에 영향을받지 않고 get_stuff에 전화 할 필요가 전혀 없습니다.

분명히이 예제는 조금 고안된 것이지만, 잘하면 그것은 asyncio.Lock이 유용한 이유에 대한 아이디어를 제공합니다. 이 실행되지 않도록 다른 coroutine을 차단하지 않고도 중요한 섹션을 보호 할 수 있습니다.은 해당 중요 섹션에 액세스해야합니다.