python 另子进程释放锁

在 Python 中，使用 `multiprocessing` 模块可以创建并管理多个并发进程。当一个进程需要在持有锁的情况下执行任务，然后返回给主线程或其他等待的进程时，应该确保正确地释放锁。这是通过 `Lock.acquire()` 方法的 `release()` 对应方法 `Lock.release()` 来完成的。

以下是一个简单的例子，展示了如何在 Python 的子进程中获取和释放锁：

import multiprocessing
from multiprocessing import Lock

# 创建一个全局锁
lock = Lock()

def worker(lock):
    # 获取锁
    lock.acquire()
    try:
        print(f"Worker {multiprocessing.current_process().name} acquired lock.")
        # 执行需要锁的任务...
        # 在任务完成后，释放锁
        lock.release()
    except Exception as e:
        print(f"Error in worker: {e}")
        # 错误发生时也要确保释放锁
        lock.release()
    finally:
        print(f"Worker {multiprocessing.current_process().name} released lock.")

if __name__ == "__main__":
    # 创建进程池
    pool = multiprocessing.Pool(processes=2)
    
    # 提交任务到进程池，每个任务都会自动获取锁
    pool.apply_async(worker, args=(lock,))
    pool.apply_async(worker, args=(lock,))
    
    # 关闭进程池，触发子进程的退出
    pool.close()
    pool.join()

在这个例子中，`Lock.acquire()` 会阻塞直到锁被释放，而在 `finally` 块中调用 `lock.release()` 确保无论任务执行成功与否，锁都能被正确地释放。如果进程遇到错误而提前终止，`release()` 也会被执行。