在python里协程使用同步锁Lock的实例

import asyncioimport functools  def unlock(lock):  print('callback releasing lock')  lock.release()  async def coro1(lock):  print('coro1 waiting for the lock')  with await lock:    print('coro1 acquired lock')  print('coro1 released lock')  async def coro2(lock):  print('coro2 waiting for the lock')  await lock  try:    print('coro2 acquired lock')  finally:    print('coro2 released lock')    lock.release()  async def main(loop):  # Create and acquire a shared lock.  lock = asyncio.Lock()  print('acquiring the lock before starting coroutines')  await lock.acquire()  print('lock acquired: {}'.format(lock.locked()))   # Schedule a callback to unlock the lock.  loop.call_later(0.1, functools.partial(unlock, lock))   # Run the coroutines that want to use the lock.  print('waiting for coroutines')  await asyncio.wait([coro1(lock), coro2(lock)]),  event_loop = asyncio.get_event_loop()try:  event_loop.run_until_complete(main(event_loop))finally:  event_loop.close()

acquiring the lock before starting coroutineslock acquired: Truewaiting for coroutinescoro1 waiting for the lockcoro2 waiting for the lockcallback releasing lockcoro1 acquired lockcoro1 released lockcoro2 acquired lockcoro2 released lock