added

Author: iavl

python/process/multiprocess.py

@@ -0,0 +1,17 @@
+import multiprocessing
+import time
+
+def process(num):
+  time.sleep(num)
+  print 'Process:', num
+
+if __name__ == '__main__':
+  for i in range(5):
+    p = multiprocessing.Process(target=process, name=str(i)+"_xxx", args=(i,))
+    p.start()
+
+  print('CPU number:' + str(multiprocessing.cpu_count()))
+  for p in multiprocessing.active_children():
+    print('Child process name: ' + p.name + ' id: ' + str(p.pid))
+
+  print('Process Ended')

python/process/myprocess.py

@@ -0,0 +1,44 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+from multiprocessing import Process, Lock, Semaphore, Queue
+import time
+
+buffer = Queue(10)
+empty = Semaphore(2)
+full = Semaphore(0)
+lock = Lock()
+
+class Consumer(Process):
+  def run(self):
+    global buffer, empty, full, lock
+    while True:
+      full.acquire()
+      lock.acquire()
+      buffer.get()
+      print('Consumer pop an element')
+      time.sleep(1)
+      lock.release()
+      empty.release()
+
+class Producer(Process):
+  def run(self):
+    global buffer, empty, full, lock
+    while True:
+      empty.acquire()
+      lock.acquire()
+      buffer.put(1)
+      print('Producer append an element')
+      time.sleep(1)
+      lock.release()
+      full.release()
+
+if __name__ == '__main__':
+  p = Producer()
+  c = Consumer()
+  p.daemon = c.daemon = True
+  p.start()
+  c.start()
+  p.join()
+  c.join()
+  print "Ended!"