python的多线程示例

#!/usr/bin/env python
 
 
import subprocess
from threading import Thread
from Queue import Queue
 
num_threads = 3
ips = ['127.0.0.1', '10.103.13.156','10.103.13.145']
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'), stderr=subprocess.STDOUT)
 if ret == 0:
 print '%s is alive!' % ip
 else:
 print '%s is down...' % 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 'main thread waiting...'
q.join()
print 'Done..'
 
if __name__ == '__main__':
 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!