同步
多进程使用的同步原语和线程的是类似的,可以通过锁来限制只能有一个进程在某时访问资源。
from multiprocessing import Process, Lock
def f(l, i):
l.acquire() # 获得num的使用权
print 'hello world', i
l.release() # 释放num的使用权
if __name__ == '__main__':
lock = Lock() # 创建好的锁 所有进程通过这个锁来协调
for num in range(10):
Process(target=f, args=(lock, num)).start()
网友评论