test_a.py

from gevent.monkey import patch_all
from gevent.lock import Semaphore

patch_all()

import aiogevent
import asyncio
import gevent


def aio_loop(coroutines):

    asyncio.set_event_loop_policy(aiogevent.EventLoopPolicy())

    for coroutine in coroutines:
        asyncio.ensure_future(coroutine)

    loop = asyncio.get_event_loop()
    loop.run_forever()
    loop.close()


class AGLock:
    def __init__(self):
        self.lock = Semaphore()

    async def __aenter__(self):
        await aiogevent.wrap_greenlet(gevent.Greenlet(self.lock.acquire))

    async def __aexit__(self, _1, _2, _3):
        await aiogevent.wrap_greenlet(gevent.Greenlet(self.lock.release))

    def __enter__(self):
        self.lock.acquire()

    def __exit__(self, _1, _2, _3):
        self.lock.release()


def g_run(i, lock):
    with lock:
        print(f"greenlet {i}")


async def aio_run(i, lock):
    async with lock:
        print(f"coroutine {i}")


def main():
    lock = AGLock()

    greenlets = []
    coros = [aio_run(i, lock) for i in range(10)]

    greenlets.extend(gevent.spawn(g_run, i, lock) for i in range(10))
    greenlets.append(gevent.spawn(aio_loop, coros))

    gevent.joinall(greenlets)


main()