aiorwlock 0.4.0

Example with async def

Requires Python 3.5+

import asyncio
import aiorwlock
loop = asyncio.get_event_loop()


async def go():
    rwlock = aiorwlock.RWLock(loop=loop)
    async with rwlock.writer:
        # or same way you can acquire reader lock
        # async with rwlock.reader: pass
        print("inside writer")
        yield from asyncio.sleep(0.1, loop=loop)

loop.run_until_complete(go())

Old-school way

Requires Python 3.3+

import asyncio
import aiorwlock
loop = asyncio.get_event_loop()


@asyncio.coroutine
def go():
    rwlock = aiorwlock.RWLock(loop=loop)
    with (yield from rwlock.writer):
        # or same way you can acquire reader lock
        # with (yield from rwlock.reader): pass
        print("inside writer")
        yield from asyncio.sleep(0.1, loop=loop)

loop.run_until_complete(go())

Fast path

By default RWLock switches context on lock acquiring. That allows to other waiting tasks get the lock even if task that holds the lock doesn’t contain context switches (await fut statements).

The default behavior can be switched off by fast argument: RWLock(fast=True).

Long story short: lock is safe by default, but if you sure you have context switches (await, async with, async for or yield from statements) inside locked code you may want to use fast=True for minor speedup.

License

aiorwlock is offered under the Apache 2 license.

Changes