testasync.py

"""
test data coming from a thread, to be processed by an asyncio process
"""
import asyncio
import threading
import time

some_queue = asyncio.Queue()
event = asyncio.Event()


async def add_item_to_queue(queue, value):
    queue.put_nowait(value)


def thread1(loop):
    while True:
        loop.call_soon_threadsafe(event.set)
        time.sleep(2)


def thread2(loop):
    while True:
        loop.call_soon_threadsafe(some_queue.put_nowait, "t2")
        time.sleep(1)


async def run():
    while True:
        item = await some_queue.get()
        print("got item: {}".format(item))


async def run_event():
    while True:
        await event.wait()
        print("awaited event, could do something now")
        event.clear()


if __name__ == "__main__":
    loop = asyncio.get_event_loop()

    t1 = threading.Thread(target=thread1, args=(loop,))
    t1.daemon = True
    t1.start()

    # t2 = threading.Thread(target=thread2, args=(loop,))
    # t2.daemon = True
    # t2.start()

    loop.create_task(run_event())
    loop.run_until_complete(run())