调试并发问题时,如果能够访问multiprocessing所提供对象的内部状态,那么这会很有用。可以使用一个方便的模块级函数启用日志记录,名为log_to_stderr()。它使用logging建立一个日志记录器对象,并增加一个处理器,使日志消息被发送到标准错误通道。
import multiprocessing import logging import sys def worker(): print('Doing some work') sys.stdout.flush() if __name__ == '__main__': multiprocessing.log_to_stderr(logging.DEBUG) p = multiprocessing.Process(target=worker) p.start() p.join()默认地,日志级别被设置为NOTSET,即不产生任何消息、通过传入一个不同的日志级别,可以初始化日志记录器并指定所需的详细程度。 运行结果: 若要直接处理日志记录器(修改其日志级别或增加处理器),可以使用get_logger()。
import multiprocessing import logging import sys def worker(): print('Doing some worke') sys.stdout.flush() if __name__ == '__main__': multiprocessing.log_to_stderr() logger = multiprocessing.get_logger() logger.setLevel(logging.INFO) p = multiprocessing.Process(target=worker) p.start() p.join()使用名multiprocessing,还可以通过logging配置文件API来配置记录器。 运行结果: