这篇文章主要介绍了Python多进程同步Lock、Semaphore、Event实例,Lock用来避免访问冲突、Semaphore用来控制对共享资源的访问数量、Event用来实现进程间同步通信,需要的朋友可以参考下
同步的方法基本与多线程相同。
1) Lock
当多个进程需要访问共享资源的时候，Lock可以用来避免访问的冲突。
import sys
def worker_with(lock, f):
with lock:
来源[email protected]搞@^&代*@码)网 fs = open(f,”a+”)
fs.write(‘Lock acquired via with\n’)
fs.close()
def worker_no_with(lock, f):
lock.acquire()
try:
fs = open(f,”a+”)
fs.write(‘Lock acquired directly\n’)
fs.close()
finally:
lock.release()
if __name__ == “__main__”:
f = “file.txt”
lock = multiprocessing.Lock()
w = multiprocessing.Process(target=worker_with, args=(lock, f))
nw = multiprocessing.Process(target=worker_no_with, args=(lock, f))
w.start()
nw.start()
w.join()
nw.join()
以上就是Python多进程同步Lock、Semaphore、Event实例的详细内容，更多请关注gaodaima搞代码网其它相关文章！
转载请注明原文链接：Python多进程同步Lock、Semaphore、Event实例
