committed from zkp

pythonkd · pythonkd · commit b875f034ad53 · 2019-03-03T13:20:37.000+08:00
diff --git a/多线程_多进程/23.py b/多线程_多进程/23.py
@@ -0,0 +1,18 @@
+from multiprocessing import Process
+import os
+
+def info(title):
+    print(title)
+    print('module name:', __name__)
+    print("parent process:", os.getppid())
+    print("process id:", os.getpid())
+
+def f(name):
+    info('function f')
+    print('hello', name)
+
+if __name__ == '__main__':
+    info('main line')
+    p = Process(target=f, args=('bob',))
+    p.start()
+    p.join()
diff --git a/多线程_多进程/24.py b/多线程_多进程/24.py
@@ -0,0 +1,33 @@
+import multiprocessing
+from time import ctime
+
+def consumer(input_q):
+    print("Into consumer:", ctime())
+    while True:
+        item = input_q.get()
+        if item is None:
+            break
+        print("pull", item, "out of q")
+        input_q.task_done()
+    print("Out of consumer:", ctime())
+
+def producer(sequence, output_q):
+    print("into producer:", ctime())
+    for item in sequence:
+        output_q.put(item)
+        print("put", item, "into q")
+    print("out of producer:", ctime())
+
+if __name__ == '__main__':
+    q = multiprocessing.JoinableQueue()
+    cons_p = multiprocessing.Process(target=consumer, args=(q,))
+    cons_p.daemon = True
+    cons_p.start()
+    cons_p_2 = multiprocessing.Process(target=consumer, args=(q,))
+    cons_p_2.start()
+
+    sequence = [1,2,3,4]
+    producer(sequence, q)
+    q.put(None)
+    q.put(None)
+    q.join()
