python多进程

luyishisi · luyishisi · commit c11ea7229a0b · 2016-01-28T09:36:45.000Z
diff --git a/python_aiml_test/start/brain-2.py b/python_aiml_test/start/brain-2.py
@@ -12,8 +12,11 @@
 # kernel.learn("std-startup.xml")
 # kernel.respond("load aiml pattern")
 print("begin game")
-a = "http://tsn.baidu.com/text2audio?tex=hello, you can talk to me! just tell me&lan=zh&per=0&pit=5&spd=2&cuid=7519663&ctp=1&tok=24.91b892cbba2c73d07f9fba69182b7960.2592000.1456136364.282335-7519663&qq-pf-to=pcqq.c2c"     
-subprocess.call(["mpg123",a])
+subprocess.PIPE
+a = "http://tsn.baidu.com/text2audio?tex=hello, you can talk to me! just tell me&lan=zh&per=0&pit=5&spd=4&cuid=7519663&ctp=1&tok=24.91b892cbba2c73d07f9fba69182b7960.2592000.1456136364.282335-7519663&qq-pf-to=pcqq.c2c"     
+p = subprocess.Popen(["mpg123",a])
+print (p.pid)
+p.wait()
 rebot = "rebot say: hello, you can talk to me! Just tell me "
 print (rebot)
 while True:
diff --git a/python_aiml_test/start/test-subprocess.py b/python_aiml_test/start/test-subprocess.py
@@ -1,4 +1,9 @@
 #coding:utf-8
 import subprocess
-subprocess.call(["mpg123","http://tsn.baidu.com/text2audio?tex=hello my name is luyi&lan=zh&per=0&pit=5&spd=2&cuid=7519663&ctp=1&tok=24.91b892cbba2c73d07f9fba69182b7960.2592000.1456136364.282335-7519663&qq-pf-to=pcqq.c2c"])
-#subprocess.call(["mpg123","http://music.baidutt.com/up/kwcawskw/dsskw.mp3"])
+#p = subprocess.popen(["mpg123","http://tsn.baidu.com/text2audio?tex=hello my name is luyi&lan=zh&per=0&pit=5&spd=2&cuid=7519663&ctp=1&tok=24.91b892cbba2c73d07f9fba69182b7960.2592000.1456136364.282335-7519663&qq-pf-to=pcqq.c2c"])
+p = subprocess.Popen('ls',shell=True,stdout=subprocess.PIPE)
+stdoutput,erroutput = p.communicate('/home/zoer')
+
+print stdoutput[0]
+print erroutput
+
diff --git a/python_multithreading/ping_LAN.py b/python_multithreading/ping_LAN.py
@@ -0,0 +1,50 @@
+#!/usr/bin python
+
+from threading import Thread
+import subprocess
+from Queue import Queue
+import datetime
+
+num_threads = 100
+ips = ['192.168.0.1','192.168.255.255']
+for i in range(25):
+    for j in range(255):
+        l = '192.168.'+str(i)+'.'+str(j)
+        ips.append(l)
+        #print (ips)
+#print(ips)
+q = Queue()
+def pingme(i,queue):
+    while True:
+        ip = queue.get()
+        #print('thread %s pinging %s' %(i,ip))
+        begin = datetime.datetime.now()
+        ret = subprocess.call('ping -c 1 %s' % ip,shell=True,stdout=open('/dev/null','w'),stderr = subprocess.STDOUT)
+        #ret.wait()
+        end = datetime.datetime.now()
+        diff = end-begin
+
+        #if diff.seconds < 10:
+         #   print ('%s time %s' %(ip,diff.seconds))
+
+        if ret == 0:
+            print ('%s is alive!' %ip)
+        elif ret == 1:
+            pass
+            #print ('%s is down...' %ip)
+        queue.task_done()
+
+for i in range(num_threads):
+    t=Thread(target=pingme,args=(i,q))
+    t.setDaemon(True)
+    t.start()
+    #print (i)
+
+for ip in ips:
+    q.put(ip)
+    #print (ip)
+
+print ('main thread waiting....')
+q.join()
+print ('done')
+            
