Push Code

coder-pig · coder-pig · commit 816abd8d3cd3 · 2018-08-02T18:10:24.000+08:00
diff --git a/Chapter 11/11_17.py b/Chapter 11/11_17.py
@@ -0,0 +1,25 @@
+"""
+多进程数据共享：Value和Array使用示例
+"""
+import multiprocessing as mp
+
+def do_something(num, arr):
+    num.value += 1
+    for i in range(len(arr)):
+        arr[i] = arr[i] * 2
+if __name__ == '__main__':
+    value = mp.Value('i', 1)
+    array = mp.Array('i', range(5))
+    print("刚开始的值：", value.value, array[:])
+
+    # 创建进程1
+    p1 = mp.Process(target=do_something, args=(value, array))
+    p1.start()
+    p1.join()
+    print("进程1操作后的值：", value.value, array[:])
+
+    # 创建进程2
+    p2 = mp.Process(target=do_something, args=(value, array))
+    p2.start()
+    p2.join()
+    print("进程2操作后的值：", value.value, array[:])
diff --git a/Chapter 11/11_18.py b/Chapter 11/11_18.py
@@ -0,0 +1,19 @@
+"""
+Manager类使用代码示例
+"""
+import multiprocessing as mp
+import os
+import time
+
+def do_something(dt):
+    dt[os.getpid()] = int(time.time())
+    print(data_dict)
+
+if __name__ == '__main__':
+    manager = mp.Manager()
+    data_dict = manager.dict()
+    for i in range(3):
+        p=mp.Process(target=do_something,args=(data_dict,))
+        p.start()
+        p.join()
+
diff --git a/Chapter 11/11_19.py b/Chapter 11/11_19.py
@@ -0,0 +1,24 @@
+"""
+Pipe管道类使用代码示例
+"""
+import multiprocessing as mp
+
+def p_1(p):
+    p.send("你好啊！")
+    print("P1-收到信息：", p.recv())
+
+def p_2(p):
+    print("P2-收到信息：", p.recv())
+    p.send("你也好啊！")
+
+
+if __name__ == '__main__':
+    pipe = mp.Pipe()
+    p1 = mp.Process(target=p_1, args=(pipe[0],))
+    p2 = mp.Process(target=p_2, args=(pipe[1],))
+
+    p1.start()
+    p2.start()
+
+    p1.join()
+    p2.join()
