多进程间通信

zhanghe06 · zhanghe06 · commit c1eade4c0b03 · 2015-04-27T22:59:17.000+08:00
diff --git a/multiprocess.py b/multiprocess.py
@@ -0,0 +1,44 @@
+# encoding: utf-8
+__author__ = 'zhanghe'
+
+from multiprocessing import Process, Queue
+import time
+import random
+
+
+def write(q):
+    """
+    &#20889;&#25968;&#25454;&#36827;&#31243;&#25191;&#34892;&#30340;&#20195;&#30721;
+    :param q:
+    :return:
+    """
+    for value in ['A', 'B', 'C']:
+        print 'Put %s to queue...' % value
+        q.put(value)
+        time.sleep(random.random())
+
+
+def read(q):
+    """
+    &#35835;&#25968;&#25454;&#36827;&#31243;&#25191;&#34892;&#30340;&#20195;&#30721;
+    :param q:
+    :return:
+    """
+    while True:
+        value = q.get(True)
+        print 'Get %s from queue.' % value
+
+
+if __name__ == '__main__':
+    # &#29238;&#36827;&#31243;&#21019;&#24314;Queue&#65292;&#24182;&#20256;&#32473;&#21508;&#20010;&#23376;&#36827;&#31243;&#65292;&#19968;&#20010;&#20889;&#65292;&#19968;&#20010;&#35835;&#65292;&#20174;&#32780;&#23454;&#29616;&#36827;&#31243;&#38388;&#36890;&#20449;&#65306;
+    queue = Queue()
+    pw = Process(target=write, args=(queue,))
+    pr = Process(target=read, args=(queue,))
+    # &#21551;&#21160;&#23376;&#36827;&#31243;pw&#65292;&#20889;&#20837;:
+    pw.start()
+    # &#21551;&#21160;&#23376;&#36827;&#31243;pr&#65292;&#35835;&#21462;:
+    pr.start()
+    # &#31561;&#24453;pw&#32467;&#26463;:
+    pw.join()
+    # pr&#36827;&#31243;&#37324;&#26159;&#27515;&#24490;&#29615;&#65292;&#26080;&#27861;&#31561;&#24453;&#20854;&#32467;&#26463;&#65292;&#21482;&#33021;&#24378;&#34892;&#32456;&#27490;:
+    pr.terminate()
