Python 中的竞争条件
多线程或多进程并发访问和修改同一共享资源时,可能出现竞争条件,导致程序结果依赖于线程或进程的执行顺序。
关键点:
- 成因: 缺乏合适的同步机制。
- 后果: 产生不可预测或错误的结果,因为线程之间存在资源竞争。
- 示例: 两个线程同时更新一个共享计数器:
counter = 0def increment(): global counter for _ in range(1000): counter += 1 # 非线程安全操作thread1 = threading.Thread(target=increment)thread2 = threading.Thread(target=increment)thread1.start()thread2.start()thread1.join()thread2.join()print(counter) # 结果可能小于2000,不可预测
如果没有正确的同步,线程会互相干扰,导致最终结果不确定。
如何避免竞争条件:
import threadingcounter = 0lock = threading.Lock()def increment(): global counter for _ in range(1000): with lock: # 保证一次只有一个线程进入该代码块 counter += 1thread1 = threading.Thread(target=increment)thread2 = threading.Thread(target=increment)thread1.start()thread2.start()thread1.join()thread2.join()print(counter) # 结果始终为2000