Multithreading example for python

大家讲道理

Release： 2016-11-09 10:58:05

Original

1243 people have browsed it

#!/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

Copy after login

Output content:

/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!

Copy after login

source：php.cn

Previous article：Python implements binary search (binary query) Next article：The client written in Python sends instructions to the server to execute the corresponding commands and return the results.

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn