Shared work queue

• Producers:

  while 1:
  
  job = make_job()
  Q.put(job)

• Consumers:

  while 1:
  
  job = Q.get()
  finish_job(job)

• Shared:
  import Queue
  
  Q = Queue.Queue(0) # or maxQsize

Previous slide

Next slide

Back to first slide

View graphic version