Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from multiprocessing import Process
- from multiprocessing import Queue
- from time import sleep
- def send(queue):
- while True:
- sleep(0.1)
- data = [1,2,3,4]
- queue.put(data)
- sleep(0)
- data.clear()
- def recv(queue):
- while True:
- sleep(0.1)
- data = queue.get()
- print('Received data: {}'.format(data))
- if __name__ == '__main__':
- q = Queue()
- p1 = Process(target=send, args=(q,))
- p2 = Process(target=recv, args=(q,))
- p1.start()
- p2.start()
- sleep(10)
- p1.join()
- p2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement