import logging
from multiprocessing import Process, Lock
def get_logger(lock: Lock):
"""
创建一个带有Lock的日志记录器，用于多进程场景。
"""
handler = logging.FileHandler('multiprocess_log.txt')
handler.acquire = lock.acquire
handler.release = lock.release
logger = logging.getLogger('mylogger')
logger.addHandler(handler)
logger.setLevel(logging.DEBUG)
return logger
def worker(lock: Lock, logger):
"""
多进程使用的工作函数，安全地记录日志。
"""
with lock:
logger.info(f'This is a log message from process {os.getpid()}')
if __name__ == '__main__':
lock = Lock()
logger = get_logger(lock)
processes = [Process(target=worker, args=(lock, logger)) for _ in range(4)]
for p in processes:
p.start()
for p in processes:
p.join()这个代码示例展示了如何使用multiprocessing模块和logging模块创建一个多进程安全的日志记录器。它定义了一个带有锁的日志记录器工厂函数get_logger，以及一个使用该记录器的工作函数worker。在主程序中，我们创建了记录器和多个工作进程，确保他们安全地记录日志信息。