Our subscriber

The subscriber class, again, has two functions defined within it: the constructor and the run function. The constructor takes in two things, the first of which is the reference of array of integers that it will consume from and the second is the condition synchronization primitive.

Within our run function, we start a loop that constantly tries to acquire the condition that has been passed into it. When we manage to acquire this lock, we print out the fact that the thread has now acquired it, and then we proceed to try and "pop" the first integer we can from the integers array that we have passed into it. Once we have successfully managed this, we then release the condition primitive, and, once again, start trying to reacquire this condition.

class Subscriber(threading.Thread):
 def __init__(self, integers, condition):
   self.integers = integers
   self.condition = condition
   threading.Thread.__init__(self)
 def run(self):
   while True:
     self.condition.acquire()
     print("Condition Acquired by Consumer: {}".format(self.name))
     while True:
       if self.integers:
         integer = self.integers.pop()
         print("{} Popped from list by Consumer: {}".format(integer, self.name))
         break
       print("Condition Wait by {}".format(self.name))
       self.condition.wait()
     print("Consumer {} Releasing Condition".format(self.name))
     self.condition.release()