Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- queue = Queue()
- max_threads = 2
- 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']
- def checkRoutes(i, q):
- # while q.qsize() != 0: # doesn't work, script never ends
- # while not q.empty(): # doesn't work, no output
- while True: # doesn't work, script never ends
- route = q.get()
- print("[%s/%s] Checking route: %s on CCS" % (i,q.qsize(),route))
- q.task_done()
- def main(args):
- '''setup threads'''
- for i in range(max_threads):
- worker = Thread(target=checkRoutes, args=(i, queue,))
- # worker.setDaemon(True)
- worker.start()
- '''feed queue'''
- for r in routes:
- queue.put(route)
- queue.join()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement