同步的方法基本与多线程相同。
1) Lock
当多个进程需要访问共享资源的时候,Lock可以用来避免访问的冲突。
复制代码 代码如下:
import multiprocessing
import sys
def worker_with(lock, f):
with lock:
fs = open(f,”a+”)
fs.write(‘Lock acquired via with\n’)
fs.close()
def worker_no_with(lock, f):
lock.acquire()
try: