Advertisement
Guest User

Untitled

a guest
Jun 17th, 2019
87
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.66 KB | None | 0 0
  1. import queue
  2. import threading
  3.  
  4. def worker(work_queue):
  5. while True:
  6. if work_queue.empty():
  7. print("Task 1 Over!")
  8. work_queue.task_done()
  9. break
  10. else:
  11. _ = work_queue.get()
  12. print(work_queue.qsize())
  13. # do actual work
  14.  
  15. def main():
  16. work_queue = queue.Queue()
  17. for i in range(10):
  18. work_queue.put("Item %d" % (i + 1))
  19.  
  20. t = threading.Thread(target=worker, args=(work_queue, ))
  21. t.setDaemon(True)
  22. t.start()
  23. print("Main Thread 1")
  24. work_queue.join()
  25. print("Main Thread 2")
  26. t.join()
  27. print("Finish!")
  28.  
  29. if __name__ == "__main__":
  30. main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement