python的多线程示例

#!/usr/bin/env python
 
 
import subprocess
from threading import Thread
from Queue import Queue
 
num_threads = 3
ips = [&＃39;127.0.0.1&＃39;, &＃39;10.103.13.156&＃39;,&＃39;10.103.13.145&＃39;]
q = Queue()
 
 
def pingme(i, queue):
    while True:
        ip = queue.get()
        print &＃39;Thread %s pinging %s &＃39; % (i, ip)
        ret = subprocess.call(&＃39;ping -c 1 %s&＃39; % ip, shell=True, stdout=open(&＃39;/dev/null&＃39;), stderr=subprocess.STDOUT)
        if ret == 0:
            print &＃39;%s is alive!&＃39; % ip
        else:
            print &＃39;%s is down...&＃39; % ip
 
# start threads
for i in xrange(num_threads):
    t = Thread(target=pingme, args=(i, q))
    t.setDaemon(True)
    t.start()
 
for ip in ips:
    q.put(ip)
 
print &＃39;main thread waiting...&＃39;
q.join()
print &＃39;Done..&＃39;
 
if __name__ == &＃39;__main__&＃39;:
    pass

输出内容：

/usr/bin/python2.7 /home/wuguowei/PycharmProjects/xplan_script/test_process/my_sub_process.py
Thread 1 pinging 127.0.0.1
main thread waiting...Thread 0 pinging 10.103.13.156
  
Thread 2 pinging 10.103.13.145
127.0.0.1 is alive!
10.103.13.156 is alive!
10.103.13.145 is alive!