python 进程间通讯(上)

一  使用queue来实现进程间的内存共享

#_*_coding:utf-8_*_
from  multiprocessing import Process,Queue
import os,time
def f(q,n):
    q.put([n,'hello'])
if __name__ == '__main__':
    #此queue不是直接导入的import Queue,这个是multiprocessing从新封装的
    q=Queue()
    #循环6个进程
    for i in range(5):
           p=Process(target=f,args=(q,i))
           p.start()
    #等待子进程完毕后在继续执行
    p.join()
    for i in range(q.qsize()):
         print q.get()

显示效果以下：

[0, 'hello', {'aa': 'bb'}]
[1, 'hello', {'aa': 'bb'}]
[2, 'hello', {'aa': 'bb'}]
[3, 'hello', {'aa': 'bb'}]
[4, 'hello', {'aa': 'bb'}]

在队列中能够存储列表，字典等类型，仍是很方便的。可是python间进程间共享内存  并非真正意义的而是须要利用第三方来实现queue就是

 

 

二进程锁LOCK

#_*_coding:utf-8_*_
from  multiprocessing import Process,Lock
import os,time
def f(l,i):
    #加锁
    l.acquire()
    print 'hello',i
    #释放锁
    l.release()
if __name__ == '__main__':
    lock=Lock()
    for i in range(5):
           p=Process(target=f,args=(lock,i)).start()
                                                   

显示效果：

hello 0
hello 1
hello 2
hello 3
hello 4

这个lock是彻底复刻的线程锁 ，没有什么改动。进程间自己内存就是独立的，没有什么征用资源的问题，因此这个把锁用处不大，可是有的时候可能须要，好比当终端显示的时候，多个进程都用的同一个终端显示。

看看父进程和子进程关系