Advertisement
Guest User

Untitled

a guest
Jul 29th, 2016
53
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.50 KB | None | 0 0
  1. from Queue import Queue
  2. import threading
  3.  
  4. def scrape(queue):
  5. global workers
  6. print worker.getName()
  7. print queue.get()
  8. queue.task_done()
  9. workers -= 1
  10.  
  11. queue = Queue(maxsize=0)
  12. threads = 10
  13. workers = 0
  14.  
  15.  
  16. with open('test.txt') as in_file:
  17. for line in in_file:
  18. queue.put(line)
  19.  
  20. while not (queue.empty()):
  21. if (threads != workers):
  22. worker = threading.Thread(target=scrape, args=(queue,))
  23. worker.setDaemon(True)
  24. worker.start()
  25. workers += 1
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement