Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing
- def worker():
- """worker function"""
- print("Worker")
- return
- if __name__ == '__main__':
- jobs = []
- for i in range(5):
- p = multiprocessing.Process(target=worker)
- jobs.append(p)
- p.start()
- #new code
- from multiprocessing import Process, Pipe
- def f(conn):
- conn.send([42, None, 'hello'])
- conn.close()
- if __name__ == '__main__':
- parent_conn, child_conn = Pipe()
- p = Process(target=f, args=(child_conn,))
- p.start()
- print(parent_conn.recv()) # prints "[42, None, 'hello']"
- p.join()
Add Comment
Please, Sign In to add comment