在Python中,可以使用multiprocessing
模块中的Lock
类来实现多进程锁。
下面是一个简单的例子,展示了如何在多进程中使用锁:
import multiprocessing
# 共享变量
counter = multiprocessing.Value('i', 0)
lock = multiprocessing.Lock()
def increment():
for _ in range(100000):
with lock:
counter.value += 1
def main():
processes = []
for _ in range(3):
process = multiprocessing.Process(target=increment)
process.start()
processes.append(process)
for process in processes:
process.join()
print(f"Counter value: {counter.value}")
if __name__ == '__main__':
main()
在上面的例子中,我们定义了一个共享变量counter
,它使用了multiprocessing.Value
来创建一个可被不同进程共享的整数值。然后我们创建了一个锁lock
,用于在多个进程之间进行同步。
increment
函数是我们要在每个进程中运行的逻辑,它使用了with lock
语句来获取锁,然后对counter.value
进行自增操作。
在main
函数中,我们创建了3个进程,并将它们添加到processes
列表中。然后通过process.join()
等待所有进程执行完毕。
最后,我们打印出counter.value
的值,以验证多进程对共享变量的修改是否正确。
注意,锁的使用应该尽可能地减少,因为它会引入额外的开销。只有在需要对共享资源进行互斥访问时,才应该使用锁。