Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import time, random, queue, threading
- url_list = queue.Queue()
- urls = [
- "google.com",
- "facebook.com",
- "tritter.com",
- "instagram.com",
- "gmail.com",
- "youtube.com",
- ]
- for i in urls:
- url_list.put(i)
- def queue_worker():
- print(threading.current_thread().name)
- while not url_list.empty():
- current_url = url_list.get()
- print("working on:", current_url)
- time.sleep(random.randint(2,10))
- print("Work done!", current_url)
- url_list.task_done()
- t1 = threading.Thread(target=queue_worker)
- t2 = threading.Thread(target=queue_worker)
- t3 = threading.Thread(target=queue_worker)
- t4 = threading.Thread(target=queue_worker)
- t1.start()
- t2.start()
- t3.start()
- t4.start()
- url_list.join()
- print("Main Thread ends")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement