Question

Redo the produce/consumer program so that it allows multiple consumers. The program will prompt the user for the number of consumers. Each consumer must be able to consume the same data before the producer produces more data. The program will prompt the user for the number of accesses (data items produced and consumed). The program will contain three Classes, SharedCell, Consumer, and Producer. Use the code presented in section 1 of the textbook as a starting point. Use the updated SharedCell code on page 408.

Run the program with the following data:

Run 1 – Consumers = 4; Accesses =4

Run 2 – Consumers =6, accesses = 2

Run 3 – Consumers = 4; Accesses = 8

Answer 1

Below is your code

import time, random

from threading import Thread, currentThread, Condition

class SharedCell(object):

"""Shared data that sequences writing before reading."""

def __init__(self):

"""Can produce but not consume
at startup."""

self.data = -1

self.writeable = True

self.condition = Condition()

  
def setData(self, data):

"""Second caller must wait until someone
has consumed the data before resetting
it."""

self.condition.acquire()

while not self.writeable:

self.condition.wait()

print("%s setting data to %d" % \

(currentThread().getName(), data))

self.data = data

self.writeable = False

self.condition.notify()

self.condition.release()

  
def getData(self):

"""Caller must wait until someone has produced
the data before accessing it."""

self.condition.acquire()

while self.writeable:

self.condition.wait()

print("%s accessing data %d" % \

(currentThread().getName(), self.data))

self.writeable = True

self.condition.notify()

self.condition.release()

return self.data

class Producer(Thread):

"""A producer of data in a shared cell."""

def __init__(self, cell, accessCount,sleepInterval):
Thread.__init__(self, name = "Producer")
self.accessCount = accessCount
self.cell = cell
self.sleepInterval = sleepInterval

def run(self):

'''Resets the data in the cell and goes to
sleep, the given number of times.'''
print("%s starting up" % self.getName())
for count in range(self.accessCount):
time.sleep(random.randint(1, self.sleepInterval))
self.cell.setData(count + 1)
print("%s is done producing\n" % self.getName())

class Consumer(Thread):

"""A consumer of data in a shared cell."""

def __init__(self, cell, accessCount,sleepInterval):
Thread.__init__(self, name = "Consumer")
self.accessCount = accessCount
self.cell = cell
self.sleepInterval = sleepInterval

def run(self):

"""Accesses the data in the cell and goes to sleep,
the given number of times."""
print("%s starting up\n" % self.getName())
for count in range(self.accessCount):
time.sleep(random.randint(1, self.sleepInterval))
value = self.cell.getData()
print("%s is done consuming\n" % self.getName())

def main():

accessCount = int(input("Enter the number of accesses: "))

cell = SharedCell()

p = Producer(cell, accessCount, 4)

c = Consumer(cell, accessCount, 4)

print("Starting the threads")

p.start()

c.start()

main()

indentation

import time, random from threading import Thread, currentThread, Condition class SharedCell (object) "Shared data that sequences writing before reading." def _-init-(3e1f): nCan produce but not consume at startup self . data =-1 self.writeable True self. condition Condition ( ) def setData (self, data) "Second caller must wait until someone has consumed the data before resetting it. n self.condition.acquire () while not self.writeable: self.condition.wait () print (ngs setting data to d" % \ (currentThread.getName,data)) self . data data self.writeable False self.condition.notify) self.condition.release()

def getData (self) Caller must wait until someone has produced the data before accessing it." self.condition.acquire ) while self.writeable: self.condition.wait () print ("33 accessing data %d" % \ (currentThread().getName(), зе1f.data)) self.writeable True self.condition.notify () self.condition.release() return self.data class Producer (Thread): "A producer of data in a shared cell.""n def init (self, cell, accessCount,sleepInterval): Thread. init (self, nameProducer) self.accessCountaccessCount self.cellcell self. sleepIntervalsleepInterval def run (self): 'Resets the data in the cell and goes to sleep, the given number of times. print ("%s starting up" % self.getName()) for count in range (self.accessCount) time.sleep (random.randint (1, self.sleepInterval)) self.cell.setData (count+ 1) print ("%s is done producing\n" self.getName())

class Consumer (Thread) A consumer of data in a shared cell."" def init (self, cell, accessCount, sleepInterval) Thread . init (self, name="consumer") self . acce33Count acce33Count self . cell cell self.sleepInterval-sleepInterval def run (self): Accesses the data in the cell and goes to sleep, the given number of times. print ("%s starting up\n" 3e1f.getName()) for count in range (self.accessCount): time.sleep (random.randint (i, self.sleepInterval)) value -self.cell.getData ) print ("%3 is done consuming\n" 3e1f.getName()) def main acce33Count int (input ("Enter the number of accesses: cell = SharedCe 11() pProducer (cell, accessCount, 4) cConsumer (cell, accessCount, 4) print("Starting the threads") p.start () С. 3tart () ")) main ()