search

PacktPublishing / Learning-Concurrency-in-Python

Learning Concurrency in Python by Packt
MIT License
77 stars 51 forks source link

pubSub.py in Chapter 04 variable issue #1

Closed ShahriyarR closed 5 years ago

ShahriyarR commented 6 years ago

In main() function there are no consumer1 and consumer2 declared but used.

def main():
  integers = []
  condition = threading.Condition()

  # Our Publisher
  pub1 = Publisher(integers, condition)
  pub1.start()

  # Our Subscribers
  sub1 = Subscriber(integers, condition)
  sub2 = Subscriber(integers, condition)
  sub1.start()
  sub2.start()

  ## Joining our Threads
  pub1.join()
  consumer1.join()
  consumer2.join()

Will send PR for this.