Queue队列的一些说明
因为/dev/null 所以紧适用于linux,而且是2的python版本
下面这个程序,是一个多线程的例子,下面num_threads =3 限定了3个进程。如果ips的值多余3个,比如说4个,也是可以顺利执行的,就是第0个线程执行完之后,会产生第二个0的线程进行执行。很厉害的样子
为什么用先进先出队列呢,因为最大线程数往往需要固定一个值。
#!/usr/bin/python
#coding=utf-8
from threading import Thread
import subprocess
from Queue import Queue #插入队列的构造方法
num_threads = 3
ips = ['192.168.1.111','192.168.1.1','192.168.1.161'] #计划需要ping的地址
q = Queue()
def pingit(i,queue):
while True:
ip = queue.get() #从队列中取出一个值
print "thread %s is pinging %s" %(i,ip)
ret = subprocess.call('ping -c 3 %s' %ip,shell=True,stdout=open('/dev/null','w')) #这里导致了,只能在linux下面的python用,正常则返回0,异常则返回一,通过是否正常返回来判断通断,stdout=open('/dev/null','w')屏蔽ping的具体信息 。 这个是通了就是返回0,不通就是返回1.
if ret !=0:
print "%s is down" %ip
queue.task_done() #在完成一项工作之后,Queue.task_done()函数向任务已经完成的队列发送一个信号
for i in xrange(num_threads):
t = Thread(target=pingit,args=(i,q))
t.setDaemon(True)
t.start()
for ip in ips:
q.put(ip) #我也很难理解,为啥把值插入队列放在后面,可能是上面的线程需要等待到有值传入,才能顺利执行吧。做过测试,放在前面也是可以的。
print "main thread is waiting..."
q.join() #Queue.join() 实际上意味着等到队列为空,再执行别的操作
print "Done..."
线程数和任务书都是2的时候的执行结果:
python thre.py
main thread is waiting...
thread 0 is pinging 192.168.1.101
thread 1 is pinging 192.168.1.102
192.168.1.101 is down
192.168.1.102 is down
Done...
不一样的时候,比如,这个脚本有问题,并非任意线程和ips都行的。
num_threads = 4
ips = ['192.168.1.111','192.168.1.1','192.168.1.161','192.168.1.101','192.168.1.102']
python thre.py
main thread is waiting...
thread 2 is pinging 192.168.1.111
thread 1 is pinging 192.168.1.1
thread 0 is pinging 192.168.1.161
thread 3 is pinging 192.168.1.101
thread 0 is pinging 192.168.1.102
192.168.1.111 is down
192.168.1.101 is down
192.168.1.102 is down
Done...
甚至,同样的代码,连续运行两次,结果都不一样。 2线程,4个ips 元素时候
=================== RESTART: C:/Users/0098917/Desktop/a.py ===================
thread 0 is pinging 192.168.11.111thread 1 is pinging 192.168.11.1
thread 0 is pinging 192.168.12.161
thread 1 is pinging 192.168.1.15
Done...
>>>
=================== RESTART: C:/Users/0098917/Desktop/a.py ===================
thread 0 is pinging 192.168.11.111thread 1 is pinging 192.168.11.1
thread 1 is pinging 192.168.12.161
thread 0 is pinging 192.168.1.15
192.168.1.15 is down
Done...
>>>