使用信号量阻塞线程,直到所有其他线程都运行了一定次数的临界区

import multiprocessing

# 创建信号量
semaphore = multiprocessing.Semaphore(5)

# 创建子进程
def worker():
    # 尝试获取信号量
    semaphore.acquire()

    # 执行临界区
    print("Worker process executing critical section")

    # 释放信号量
    semaphore.release()

# 创建子进程
p = multiprocessing.Process(target=worker)

# 启动子进程
p.start()

# 等待子进程结束
p.join()

# 所有其他线程都已完成执行
print("All threads have completed their critical sections")