lambda_multiprocessing

lambda_multiprocess.py

from multiprocessing import Process, Pipe

def add_two(x, conn):
  conn.send([x+2])
  conn.close()

processes = []
parent_connections = []

xs = [1,2,3,4,5]

for x in xs:
    parent_conn, child_conn = Pipe()
    parent_connections.append(parent_conn)
    process = Process(target=add_two, args=(x, child_conn,))
    processes.append(process)
    process.start()

for process in processes:
    process.join()

results = [p.recv()[0] for p in parent_connections]
print(results)