1. 程式人生 > >使用pyhton採用多執行緒方式ping IP

使用pyhton採用多執行緒方式ping IP

在使用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'