我被告知在Multiprocessing中无法使用日志记录。您必须进行并发控制,以防止多处理程序干扰日志记录。
但是我进行了一些测试,似乎在Multiprocessing中使用日志记录没有问题。
import time
import logging
from multiprocessing import Process, current_process, pool
# setup log
logger = logging.getLogger(__name__)
logging.basicConfig(level=logging.DEBUG,
format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
datefmt='%a, %d %b %Y %H:%M:%S',
filename='/tmp/test.log',
filemode='w')
def func(the_time, logger):
proc = current_process()
while True:
if time.time() >= the_time:
logger.info('proc name %s id %s' % (proc.name, proc.pid))
return
if __name__ == '__main__':
the_time = time.time() + 5
for x in xrange(1, 10):
proc = Process(target=func, name=x, args=(the_time, logger))
proc.start()
从代码中可以看出来。
我故意让子进程在开始后的5秒钟内同时写日志,以增加冲突的可能性。但是根本没有任何冲突。
所以我的问题是,我们能在多进程中使用logging吗?为什么有那么多帖子说我们不能?