##Using Queue with multiprocessing – Chapter : Process Based Parallelism
import multiprocessing
import random
import time class producer(multiprocessing.Process):
def __init__(self, queue):
multiprocessing.Process.__init__(self)
self.queue = queue def run(self) :
for i in range():
item = random.randint(, )
self.queue.put(item)
print ("Process Producer : item %d appended to queue %s"\
% (item,self.name))
time.sleep()
print ("The size of queue is %s"\
% self.queue.qsize()) class consumer(multiprocessing.Process):
def __init__(self, queue):
multiprocessing.Process.__init__(self)
self.queue = queue def run(self):
while True:
if (self.queue.empty()):
print("the queue is empty")
break
else:
time.sleep()
item = self.queue.get()
print ('Process Consumer : item %d popped from by %s \n'\
% (item, self.name))
time.sleep() if __name__ == '__main__':
queue = multiprocessing.Queue()
process_producer = producer(queue)
process_consumer = consumer(queue)
process_producer.start()
process_consumer.start()
process_producer.join()
process_consumer.join()