Advertisement
Guest User

Untitled

a guest
Feb 19th, 2018
72
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.57 KB | None | 0 0
  1.  
  2. from multiprocessing import Process
  3. from multiprocessing import Queue
  4. from time import sleep
  5.  
  6. def send(queue):
  7. while True:
  8. sleep(0.1)
  9. data = [1,2,3,4]
  10. queue.put(data)
  11. sleep(0)
  12. data.clear()
  13.  
  14. def recv(queue):
  15. while True:
  16. sleep(0.1)
  17. data = queue.get()
  18. print('Received data: {}'.format(data))
  19.  
  20. if __name__ == '__main__':
  21. q = Queue()
  22. p1 = Process(target=send, args=(q,))
  23. p2 = Process(target=recv, args=(q,))
  24. p1.start()
  25. p2.start()
  26. sleep(10)
  27. p1.join()
  28. p2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement