added pool,lock,queue,pipe

Author: learnp

Multiprocessing/multiprocessing_lock.py

@@ -18,14 +18,10 @@ def withdraw(balance, lock):
 if __name__ == '__main__':
     balance = multiprocessing.Value('i', 200)
     lock = multiprocessing.Lock()
-
     d = multiprocessing.Process(target=deposit, args=(balance,lock))
     w = multiprocessing.Process(target=withdraw, args=(balance,lock))
-
     d.start()
     w.start()
-
     d.join()
     w.join()
-
     print(balance.value)

Multiprocessing/multiprocessing_pool.py

@@ -0,0 +1,11 @@
+from multiprocessing import Pool
+
+
+def f(n):
+    return n*n
+
+if __name__ == "__main__":
+    p = Pool(processes=3)
+    result = p.map(f,[1,2,3,4,5])
+    for n in result:
+        print(n)

Multiprocessing/multiprocessing_queue_pipe.py

@@ -0,0 +1,20 @@
+import multiprocessing
+
+def calc_square(numbers, q):
+    for n in numbers:
+        q.put(n*n)
+
+if __name__ == "__main__":
+    numbers = [2,3,5]
+    q = multiprocessing.Queue()
+    p = multiprocessing.Process(target=calc_square, args=(numbers,q))
+
+    p.start()
+    p.join()
+
+    while q.empty() is False:
+        print(q.get())
+
+
+
+