1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
import asyncio
from aioprocessing import AioManager
from concurrent.futures import ProcessPoolExecutor
async def _do_coro_proc_work(q, val, val2):
ok = val + val2
print("Passing {} to parent".format(ok))
await q.coro_put(ok)
item = q.get()
print("got {} back from parent".format(item))
def do_coro_proc_work(q, val, val2):
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.run_until_complete(_do_coro_proc_work(q, val, val2))
async def do_work(q):
print("hi")
loop.run_in_executor(ProcessPoolExecutor(),
do_coro_proc_work, q, 1, 2)
item = await q.coro_get()
print("Got {} from worker".format(item))
item = item + 25
q.put(item)
if __name__ == "__main__":
m = AioManager()
q = m.AioQueue()
loop = asyncio.get_event_loop()
loop.run_until_complete(do_work(q))
|
