python的多線程示例
#!/usr/bin/env pythonimport 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</pre>
輸出內容:
/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!
本文由用戶 aiguang 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!