Pfthb

I'm trying to run asyncio in a Thread. The reason I'm doing this is, that I want to communicate with asyncio from a non async main thread.
So here is my code

import asyncio
import threading

async def consume(input_q, output_q):
 while True:
 item = await input_q.get()
 print(item)
 output_q.put("hello back")

async def run(input_q, output_q):
 asyncio.ensure_future(consume(input_q, output_q))
 while True:
 await asyncio.sleep(1)
 print("message")

def run_in_thread(loop,input_q,output_q):
 asyncio.set_event_loop(loop)
 loop.run_until_complete(run(input_q, output_q))
loop = asyncio.new_event_loop()
input_q = asyncio.Queue(loop=loop)
output_q = asyncio.Queue(loop=loop)
thread = threading.Thread(target=run_in_thread ,args=(loop, input_q, output_q))
thread.start()
time.sleep(5)
asyncio.run_coroutine_threadsafe(input_q.put("hello input"), loop)
time.sleep(2)
item = asyncio.run_coroutine_threadsafe(output_q.get_nowait(), loop).result()
assert "hello back" in item
print(item)
loop.call_soon_threadsafe(loop.stop)
thread.join()

I'm able to put messages to the input queue from the main thread. Bun unfortunately not able to read from the output_q. Is there any solution for this?
Getting the error on this line:

item = asyncio.run_coroutine_threadsafe(output_q.get_nowait(), loop).result() 
--> raises QueueEmpty

Maybe using multiprocessing or whatever. What I would like to do is run the above functions and communicate from another process or thread with them which doesn't use async. Thanks a lot for any hint!

PS: I'm using python 3.5