举个例子:
我们现在要同时运行这些脚本,来达到快速启动所有的java程序,如果我们只用多线程的话,线程是不会返回消息给父进程,我们如何才能知道这些程序是启动成功了呢?
所以我们用到了队列来管理。
我试过gevent,但是会在command这里造成阻塞
gevent代码如下 如果有朋友知道如何优化,请您告诉我
#!/usr/bin/python2.7# -*- coding:utf-8 -*-import os,sysfrom datetime import datetimeimport commandsimport gevent.monkeygevent.monkey.patch_os()import gevent def servers(): servers=commands.getoutput('''ls /data/program/payment/ | grep 'payment' ''') servers=servers.split('\n') return servers def handle(servername): if sys.argv[1] == 'start' or sys.argv[1] == 'stop' or sys.argv[1] == 'restart': print '\033[1;31;40m' print '========================>>>go to handle %s<>put %s in queue<< 0: #循环在队列中取结果,直到循环结束 data=in_q.get() n -= 1 print '\033[1;31;40m' print data print '\033[0m' print '\033[1;31;40m' print 'consumer was done!!!!!!!' print '\033[0m' if __name__ == '__main__': s=servers() q = queue() t1 = thread(target=consumer, args=(s,q,)) #消费者在队列中获取结果,前面的函数内部已经循环获取 for i in s: t2=thread(target=producer, args=(i,q,)) #讲线程进行管理,放入队列 t2.start() #启动生产者线程# t2.join() #启动生产者以后放弃校验线程是否结束,进行并发,因为我们是把线程放入队列进行管理的,所以不用在这里等待线程结束,如果使用了join这里会阻塞我们的程序。线程结束后,消费者会通知父进程线程已经结束。 t1.start() #启动消费者线程 t1.join() #在获取完成之前进行线程的阻塞
简单的说下join这个方法:
调用thread.join将会使主调线程堵塞,直到被调用线程运行结束或超时。参数timeout是一个数值类型,表示超时时间,如果未提供该参数,那么主调线程将一直堵塞到被调线程结束。
以上所述就是本文的全部内容了,希望大家能够喜欢。
