python多线程Ping

kaywang

• #!/usr/bin/python
  
  
• # -*- coding: utf-8 -*-
  
• 
  
• import os
  
• import threading
  
• import Queue
  
• 
  
• queue = Queue.Queue()
  
• _thread = 150
  
• 
  
• f = open('ip.list','r')
  
• for ip in f.readlines():
  
•     k = ip.strip()
  
•     queue.put(k)
  
• f.close()
  
• 
  
• def check(i,q):
  
•         while True:
  
•                 ip=q.get()
  
•                 data = os.system("ping -c 1 %s > /dev/null 2>&1" % ip)
  
•                 if data==0:
  
•                         print "%s: running ok\n" % ip
  
•                 else:
  
•                         print "%s: running no\n" % ip
  
•                 q.task_done() #表示queue.join()已完成队列中提取元组数据
  
• for i in range(_thread):
  
•         run=threading.Thread(target=check,args=(i,queue)) #创建一个threading.Thread()的实例，给它一个函数和函数的参数
  
•         run.setDaemon(True)#这个True是为worker.start设置的，如果没有设置的话会挂起的，因为check是使用循环实现的
  
•         run.start()
  
• queue.join()#线程队列执行关闭
  
• print "ping task running done."