信号灯机制解决独木桥并发问题：Python代码示例

独木桥问题是并发编程中的经典问题，它描述了多个线程试图同时访问同一个共享资源（独木桥）时可能出现的竞争条件。本文将介绍如何使用信号灯机制来解决这个问题，并提供Python代码示例。

问题描述

假设有一座独木桥，一次只能允许一个人通过。如果有两个人同时想要过桥，就会发生冲突。我们需要一种机制来确保同一时间只有一人能够过桥。

解决方案：信号灯机制

信号灯（Semaphore）是一种用于控制对共享资源访问的同步机制。它维护一个内部计数器，表示可用资源的数量。

• 当计数器大于0时，表示有可用资源，线程可以获取资源并继续执行。* 当计数器等于0时，表示没有可用资源，线程会被阻塞，直到有资源可用。

我们可以使用一个信号量来表示独木桥的可用情况。初始时，信号量的值为1，表示桥是可用的。当一个人想要过桥时，就尝试获取信号量。如果获取成功，则可以过桥；否则，就需要等待，直到信号量被释放。

Python代码示例pythonimport threadingimport timeimport random

创建一个信号量，初始值为1，表示桥可用bridge_available = threading.Semaphore(1)

定义过桥函数def cross_bridge(person): # 尝试获取信号量 with bridge_available: print(f'{person} 正在过桥...') time.sleep(random.randint(1, 3)) # 模拟过桥时间 print(f'{person} 已经过桥!')

创建多个线程模拟过桥的人people = ['Alice', 'Bob', 'Charlie', 'David']threads = []for person in people: thread = threading.Thread(target=cross_bridge, args=(person,)) threads.append(thread)

启动线程for thread in threads: thread.start()

等待所有线程执行完毕for thread in threads: thread.join()

print('所有人已安全过桥!')

代码解释

1. 首先，我们使用 threading.Semaphore(1) 创建一个信号量，并将其初始值设置为1，表示桥当前可用。2. cross_bridge 函数模拟了过桥的过程。在函数内部，我们使用 with bridge_available: 语句来获取信号量。 * 如果信号量可用，则线程会获取信号量并继续执行。 * 如果信号量不可用，则线程会被阻塞，直到信号量被释放。3. 当线程获取到信号量后，会打印信息表示正在过桥，并模拟过桥所需的时间。4. 过桥完成后，线程会释放信号量，允许其他线程获取资源。5. 我们创建了多个线程，每个线程代表一个想要过桥的人，并使用 thread.start() 启动线程。6. 最后，我们使用 thread.join() 等待所有线程执行完毕，确保所有人都安全过桥。

总结

使用信号灯机制可以有效地解决独木桥并发问题，确保同一时间只有一人能够过桥。该机制简单易懂，并且在实际应用中被广泛使用。希望本文能够帮助您理解信号灯机制及其在并发编程中的应用。