python_ptt_0206.py

import asyncio
import threading
import time
from typing import TYPE_CHECKING

if TYPE_CHECKING:
    from asyncio import AbstractEventLoop


async def foo(condition):
    loop = asyncio.get_event_loop()
    print("Foo loop id:", id(loop))
    a = 1
    while True:
        print(f"{time.strftime('%X')}: do {a}")
        a += 1
        async with condition:
            await condition.wait()


def non_async_func(loop: "AbstractEventLoop", condition):
    print("non_async_func loop id:", id(loop))
    time.sleep(1)
    loop.create_task(release(condition))


async def release(condition):
    loop = asyncio.get_event_loop()
    print("Release loop id:", id(loop))

    async with condition:
        condition.notify_all()
    print("notify")


async def main():
    loop = asyncio.get_event_loop()
    print("main loop id:", id(loop))

    condition = asyncio.Condition()

    job1 = loop.run_in_executor(None, non_async_func, loop, condition)
    job2 = loop.create_task(foo(condition))
    await asyncio.gather(job1, job2)


if __name__ == "__main__":
    asyncio.run(main())

Version 2

more wrong

import asyncio
import threading
import time
from typing import TYPE_CHECKING

if TYPE_CHECKING:
    from asyncio import AbstractEventLoop

# DeprecationWarning: There is no current event loop
main_loop = asyncio.get_event_loop()


async def foo(condition):
    loop = asyncio.get_event_loop()
    print("Foo loop id:", id(loop))
    a = 1
    while True:
        print(f"{time.strftime('%X')}: do {a}")
        a += 1
        async with condition:
            await condition.wait()


def non_async_func(condition):
    print("non_async_func loop id:", id(main_loop))
    time.sleep(1)
    main_loop.create_task(release(condition))


async def release(condition):
    loop = asyncio.get_event_loop()
    print("Release loop id:", id(loop))

    async with condition:
        condition.notify_all()
    print("notify")


async def main():
    loop = asyncio.get_event_loop()
    print("main loop id:", id(loop))

    condition = asyncio.Condition()

    job1 = loop.run_in_executor(None, non_async_func, condition)
    job2 = loop.create_task(foo(condition))
    await asyncio.gather(job1, job2)


if __name__ == "__main__":
    print("main_loop", id(main_loop))
    main_loop.run_until_complete(main())