python 进程间通信(上)

时间:2022-12-27 12:29:32

一  使用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():
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是完全复刻的线程锁 ,没有什么改动。进程间本身内存就是独立的,没有什么征用资源的问题,所以这个把锁用处不大,但是有的时候可能需要,比如当终端显示的时候,多个进程都用的同一个终端显示。

看看父进程和子进程关系

python 进程间通信(上)