Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import queue
- import multiprocessing
- def producer(q):
- for i in range(10):
- q.put(i)
- def consume(q):
- while True:
- item = q.get()
- if item is None:
- break
- print(item)
- if __name__ == '__main__':
- queue = queue.Queue() # Using queue.Queue instead of multiprocessing.Queue
- m1 = multiprocessing.Process(target=producer, args=(queue,))
- m2 = multiprocessing.Process(target=consume, args=(queue,))
- m1.start()
- m2.start()
- queue.put("sudh")
- m1.join()
- m2.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement