Advertisement
Guest User

Untitled

a guest
Jul 7th, 2015
177
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. queue = Queue()
  2. max_threads = 2
  3. routes = ['1.1.1.1','2.2.2.2','3.3.3.3','4.4.4.4','5.5.5.5','6.6.6.6','7.7.7.7','8.8.8.8']
  4.  
  5. def checkRoutes(i, q):
  6.     # while q.qsize() != 0: # doesn't work, script never ends
  7.     # while not q.empty():  # doesn't work, no output
  8.     while True:             # doesn't work, script never ends
  9.             route = q.get()
  10.             print("[%s/%s] Checking route: %s on CCS" % (i,q.qsize(),route))
  11.         q.task_done()
  12.  
  13. def main(args):
  14.     '''setup threads'''
  15.     for i in range(max_threads):
  16.         worker = Thread(target=checkRoutes, args=(i, queue,))
  17.         # worker.setDaemon(True)
  18.         worker.start()
  19.  
  20.     '''feed queue'''
  21.     for r in routes:
  22.         queue.put(route)
  23.  
  24.     queue.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement