Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import queue
- import threading
- def worker(work_queue):
- while True:
- if work_queue.empty():
- print("Task 1 Over!")
- work_queue.task_done()
- break
- else:
- _ = work_queue.get()
- print(work_queue.qsize())
- # do actual work
- def main():
- work_queue = queue.Queue()
- for i in range(10):
- work_queue.put("Item %d" % (i + 1))
- t = threading.Thread(target=worker, args=(work_queue, ))
- t.setDaemon(True)
- t.start()
- print("Main Thread 1")
- work_queue.join()
- print("Main Thread 2")
- t.join()
- print("Finish!")
- if __name__ == "__main__":
- main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement