使用pyhton採用多執行緒方式ping IP
阿新 • • 發佈:2019-02-02
在使用ping命令ping多個網路地址時,一般是一個一個的ping,等待前一個結果出來後再ping後一個IP地址,本文使用python多執行緒寫了一個簡單的小程式,它支援同時ping多個IP地址。
需要注意的有以下幾點:
1、本程式碼將要處理的IP地址放入了Queue中,而Queue是執行緒安全的,能夠確保每一次操作都是原子操作。這樣就省去了自己管理多執行緒資源申請的問題。
2、在pingIP地址時,使用了subprocess的call函式來呼叫ping命令。
subprocess的作用是開啟子程序來執行命令。
3、ping -c 1 ip 命令的作用是隻ping一次該IP地址就返回結果。
流程介紹
程式一開始開啟三個子執行緒,每一個執行緒都執行函式pingme,進入一個迴圈等待中。
然後主執行緒將所有需要的IP塞到Queue中,q.join()的呼叫是用來等待佇列中的所有元素確保都被處理,也就是主執行緒等待三個子執行緒的while迴圈都退出,子執行緒也退出了,主執行緒再繼續執行。
程式碼如下:
from threading import Thread
import subprocess
from Queue import Queue
num_threads=3
ips=['127.0.0.1','192.168.3.119','183.232.231.173' ,'183.232.231.174','183.232.231.175']
q=Queue()
def pingme(i,queue):
while True:
ip=queue.get()
print 'Thread %s pinging %s' %(i,ip)
ret=subprocess.call('ping -c 1 %s' % ip,shell=True,stdout=open('/dev/null','w'),stderr=subprocess.STDOUT)
if ret==0:
print '%s is alive!' %ip
elif ret==1:
print '%s is down...'%ip
queue.task_done()
#start num_threads threads
for i in range(num_threads):
t=Thread(target=pingme,args=(i,q))
t.setDaemon(True)
t.start()
for ip in ips:
q.put(ip)
print 'main thread waiting...'
q.join();
print 'Done'