例1： 子进程创建
from multiprocessing import Process
import os
def get_process(info):
print info
# *nix系统才有getpid及getppid方法
#print 'Process ID:', os.getpid()
#print 'Parent process ID:', os.getppid()
def func(name):
get_process('In func:')
print "Hello,", name
if __name__ == "__main__":
get_process('In main:')
p = Process(target=func, args=('marsloo',))
# 开始子进程
p.start()
# 等待子进程结束
p.join() #避免僵尸进程
例2：进程间通信
1. 使用Queue对象可以实现进程间通信，并且Queue对象是线程及进程安全的：
from multiprocessing import Queue, Process
def func(q):
q.put([1, 'str', None])
if __name__ == "__main__":
q = Queue()
p = Process(target=func, args=(q,))
p.start()
p.join()
print q.get()
2.
Pipe
Pipe对象返回的元组分别代表管道的两端，管道默认是全双工，两端都支持send和recv方法，两个进程分别操作管道两端时不会有冲突，两个进程对管道一端同时读写时可能会有冲突
3. 共享内存对象
在进程间共享状态可以使用multiprocessing.Value和multiprocessing.Array这样特殊的共享内存对象
from multiprocessing import Process, Value, Array
def func(n, a):
n.value = 3.1415926
for i in range(len(a)):
a[i] = -i
if __name__ == "__main__":
# 'd'表示浮点型数据，'i'表示整数
n = Value('d', 0.0)
a = Array('i', range(10))
print a[:]
p = Process(target=func, args=(n, a,))
p.start()
p.join()
print n.value
print a[:]
例3 ：主线程开启多个线程去干活，每个线程需要完成的时间不同，干完活以后都要通知给主线程（线程间通信可以通过lock global 变量来实现）
from multiprocessing import Queue
import threading
import time
import random
q = Queue()
threads=[]
class MyThread(threading.Thread):
def __init__(self,q,t,j):
super(MyThread,self).__init__()
self.q=q
self.t=t
self.j=j
def run(self):
time.sleep(self.j)
# 通过q.put()方法，将每个子线程要返回给主线程的消息，存到队列中
self.q.put("我是第%d个线程，我睡眠了%d秒,当前时间是%s" % (self.t, self.j,time.ctime()))
for i in range(15):
j=random.randint(1,8)
threads.append(MyThread(q,i,j))
# 循环开启所有子线程
for mt in threads:
mt.start()
print('进程开启时间：%s'%(time.ctime()))
count = 0
while True:
if not q.empty():
print(q.get())
count+=1
if count==15:
break
| 
转播
