在并行编程中,锁是一种同步机制,用于控制对共享资源的访问。锁可以确保在任何给定时刻只有一个线程可以访问被保护的代码块或共享资源。以下是一个使用锁的代码示例:
import threading
# 创建一个锁对象
lock = threading.Lock()
# 共享资源
shared_resource = 0
def increment():
global shared_resource
# 获取锁
lock.acquire()
try:
# 对共享资源进行操作
shared_resource += 1
finally:
# 释放锁
lock.release()
# 创建多个线程进行并行操作
threads = []
for _ in range(10):
t = threading.Thread(target=increment)
threads.append(t)
t.start()
# 等待所有线程执行完毕
for t in threads:
t.join()
print(shared_resource) # 输出结果为10
在上述代码中,我们使用了threading.Lock()
创建了一个锁对象lock
。在increment()
函数中,我们首先调用lock.acquire()
获取锁,然后对共享资源进行操作,最后调用lock.release()
释放锁。
通过使用锁,我们确保在同一时刻只有一个线程可以访问共享资源,从而避免了并发访问造成的竞态条件和数据不一致的问题。
上一篇:并行编程中的READ_ONCE和WRITE_ONCE
下一篇:并行编程中的值语义