清华大佬耗费三个月吐血整理的几百G的资源,免费分享!....>>>
#!/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!