import multiprocessing as mp
def send(conn):
"""send obj to pipe"""
for i in range(10):
conn.send(i)
print("send:", i)
conn.close()
def transform(func, conn):
"""receive input from pipe, transform it"""
try:
while True:
i = conn.recv()
print('transform:', func(i))
except EOFError:
conn.close()
c_1, c_2 = mp.Pipe()
p1 = mp.Process(target=send, args=(c_1,))
p2 = mp.Process(target=transform, args=(lambda x: x ** 2, c_2,))
p1.start()
p2.start()
p1.join()
p2.join()
In python documentation it's stated, recv() Blocks until there its something to
receive. Raises EOFError if there is nothing left to receive and the other end
was closed.
But why this code doesn't terminate?
--
https://mail.python.org/mailman/listinfo/python-list
