multiprocessing

Author: 罗晟

LP4E-examples/dist.py renamed to LP4E-examples/dist_eg.py

@@ -0,0 +1,23 @@
+# __author__ = 'admin'
+# from multiprocessing import Process
+# def worker():
+# 	print 'worder'
+# 	return
+# if __name__ == '__main__':
+# 	jobs = []
+# 	for i in range(5):
+# 		p = Process(target=worker)
+# 		jobs.append(p)
+# 		p.start()
+
+
+
+from multiprocessing import Process
+
+def f(name):
+    print 'hello', name
+
+if __name__ == '__main__':
+    p = Process(target=f, args=('bob',))
+    p.start()
+    p.join()

LP4E-examples/function.py renamed to LP4E-examples/function_eg.py

@@ -0,0 +1,11 @@
+__author__ = 'admin'
+import multiprocessing
+def worker():
+	print 'Worker'
+	return
+if __name__ == '__main__':
+	jobs = []
+	for i in range(5):
+		p = multiprocessing.Process(target=worker)
+		jobs.append(p)
+		p.start()

LP4E-examples/iter.py renamed to LP4E-examples/iter_eg.py

@@ -0,0 +1,11 @@
+__author__ = 'admin'
+import multiprocessing
+def worker(num):
+	print 'worker:',num
+	return
+if __name__ == '__main__':
+	jobs = []
+	for i in range(5):
+		p = multiprocessing.Process(target=worker, args=(i,))
+		jobs.append(p)
+		p.start()

LP4E-examples/list.py renamed to LP4E-examples/list_eg.py

@@ -0,0 +1,31 @@
+__author__ = 'admin'
+import multiprocessing
+import time
+import sys
+
+def daemon():
+	p = multiprocessing.current_process()
+	print 'Starting:', p.name, p.pid
+	sys.stdout.flush()
+	time.sleep(2)
+	print 'Exiting:',p.name, p.pid
+	sys.stdout.flush()
+
+def non_daemon():
+	p = multiprocessing.current_process()
+	print 'starting',p.name,p.pid
+	sys.stdout.flush()
+	print 'Exting:',p.name,p.pid
+	sys.stdout.flush()
+
+
+if __name__ == '__main__':
+	d = multiprocessing.Process(name='daemon', target=daemon)
+	d.daemon = True #no block the main process
+
+	n = multiprocessing.Process(name='non_daemon', target=non_daemon)
+	n.daemon = False #block the main process
+
+	d.start()
+	time.sleep(1)
+	n.start()

LP4E-examples/multiprocessing_basic.py

@@ -0,0 +1,38 @@
+__author__ = 'admin'
+import multiprocessing
+import sys
+import time
+def exit_error():
+	sys.exit(1)
+
+def exit_ok():
+	return 0
+
+def return_value():
+	return 0
+
+def raises():
+	raise  RuntimeError('There was na error!') #except error code 1
+
+def terminated():
+	time.sleep(2)
+
+if __name__ == '__main__':
+	jobs = []
+	for f in [exit_error, exit_ok, return_value,raises,terminated]:
+		print 'Starting process for', f.func_name
+		j = multiprocessing.Process(target =f, name =f.func_name)
+		jobs.append(j)
+		j.start()
+
+	jobs[-1].terminate()
+
+	for j in jobs:
+		j.join()
+		print '%15s.exitcode = %s' % (j.name, j.exitcode)
+
+
+
+
+
+

LP4E-examples/multiprocessing_basic2.py

@@ -0,0 +1,12 @@
+__author__ = 'admin'
+import multiprocessing
+import multiprocessing_import_worker
+
+if __name__ == '__main__':
+	jobs = []
+	for i in range(5):
+		p = multiprocessing.Process(
+			target = multiprocessing_import_worker.worker,
+		)
+		jobs.append(p)
+		p.start()